但如果自上次创建检查点以来对delta表没有任何更改,我将得到以下错误:java.lang.IllegalStateException: State of the checkpoint:144) at org.apache.spark.sql.delta.Checkpoints$anonfun$checkpoint<
spark.sql("CREATE TABLE {0} USING DELTA LOCATION '{1}'".format(tbl_name, tbl_path))类似于此链接中的python示例每当我运行时,表都不会与数据一起插入。也没有调试日志消息。$anonfun$run$14(alterDeltaTableCommands.scala:292)
at com.databricks.
2016-04-28 18:26:55,483 INFO [org.apache.spark.streaming.CheckpointWriter] [pool-16-thread-1] - CheckpointINFO [org.apache.spark.streaming.CheckpointWriter] [pool-16-thread-1] - Checkpoint for time 1461882407000INFO [org.apache.spark.streaming.Checkpoi