在執行Df.write.format("parquet").save("D:\\Work\\Spark\\Data\\Df.parquet")時出現以下例外提示
java.lang.RuntimeException: Error while encoding: java.lang.RuntimeException: java.lang.Integer is not a valid external type for schema of string。
但在執行Df.show(false)時 可以正常執行。請大神們診斷出策,謝謝!!!
uj5u.com熱心網友回復:
java.lang.Integer is not a valid external type for schema of string。估計是你的StructType中的StructField定義的某個欄位為String型別,但是你RDD[Row]中對應的卻為Integer型別
仔細檢查
你可以把你原始碼貼出了
uj5u.com熱心網友回復:
從報錯資訊的字面含義看出,是運行時的型別轉換錯誤。能不能把例子給出來?
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/58940.html
標籤:Spark
