使用以下代碼在 Databricks 中獲取此錯誤。誰能解釋這個錯誤是什么意思?
df.writeStream \
.format("delta") \
.option("checkpointLocation", CHECKPOINT_LOCATION) \
.trigger(once=True) \
.start(DELTA_FILE_LOCATION)
錯誤:
java.lang.IllegalArgumentException: Input marker does not start with input path!
uj5u.com熱心網友回復:
我通過添加解決了這個問題 .option("cloudFiles.useIncrementalListing", False)
https://docs.databricks.com/spark/latest/structured-streaming/auto-loader-s3.html
轉載請註明出處,本文鏈接:https://www.uj5u.com/shujuku/386969.html
