Spark from 1.3.0 after upgrading to spark1.5.1, data from protobuffer parsed into a Java object is normal, to convert Java objects to dataframe and register into a temporary table, query the temporary table, all the string display abnormal,
To spark - shell with sparksql perform the same SQL, shows the result is normal,
Daniel, please help me locate the problem, thank you!
1> Analytical results: normal
2> The use of parsed sparkcontext data into dataframe, registered into a temporary table data, l query exception:
3> Put in storage after query: abnormal
4 & gt; Spark - shell using hivecontext perform the same SQL, the query results showed normal: