無法推斷模式為拚花

[bciampa]

我有筆記本這段代碼:

val streamingDataFrame = incomingStream。selectExpr(“鑄(身體字符串)內容”).withColumn(“情緒”,toSentiment(“內容”)美元)

進口org.apache.spark.sql.streaming.Trigger。ProcessingTime val結果= streamingDataFrame .writeStream.format .option(“鋪”)(“路徑”,“/ mnt / TwitterSentiment”) .option (“checkpointLocation”、“/ mnt / temp /檢查”).start () < / p > < p >…它總是導致這個錯誤。難住了,任何建議嗎? < / p > < pre > org.apache.spark.sql。AnalysisException:無法推斷模式為拚花。它必須手動指定;< br >

[Kaniz]

你好@bciampa!我的名字叫Kaniz,我這裏的技術主持人。很高興認識你,謝謝你的問題!看看你的同行在論壇上先回答你的問題。否則我們將很快跟進與回複。

[werners1]

似乎是一個無效的文件拚花。我的猜測是傳入的數據混合類型(相同的列)或/無效的結構不同。