diff --git a/xtable-core/src/main/java/org/apache/xtable/delta/DeltaConversionUtils.java b/xtable-core/src/main/java/org/apache/xtable/delta/DeltaConversionUtils.java index 3401df844..225d13c64 100644 --- a/xtable-core/src/main/java/org/apache/xtable/delta/DeltaConversionUtils.java +++ b/xtable-core/src/main/java/org/apache/xtable/delta/DeltaConversionUtils.java @@ -39,7 +39,8 @@ static SparkSession buildSparkSession(Configuration conf) { .set( "spark.sql.catalog.spark_catalog", "org.apache.spark.sql.delta.catalog.DeltaCatalog") - .set("spark.databricks.delta.constraints.allowUnenforcedNotNull.enabled", "true"); + .set("spark.databricks.delta.constraints.allowUnenforcedNotNull.enabled", "true") + .set("spark.databricks.delta.checkpoint.exceptionThrowing.enabled", "true"); SparkSession.Builder builder = SparkSession.builder().config(sparkConf); conf.forEach( entry ->