spark從1.3.0升級到spark1.5.1之后,資料從protobuffer決議成java物件是正常的,將java物件轉換成dataframe,注冊成臨時表,查詢臨時表,所有的字串顯示例外了。
到spark-shell上使用sparksql執行相同sql,顯示結果正常。
請大牛幫忙定位一下問題,謝謝!
1> 決議結果:正常

2> 決議之后的使用sparkcontext將資料轉為dataframe,注冊成l臨時表資料,查詢例外:

3> 入庫之后查詢:例外

4> spark-shell上使用hivecontext執行相同sql,查詢結果顯示正常:

轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/84578.html
標籤:Spark
上一篇:Hive中注冊UDF后出現例外
