问题描述
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,查询结果显示正常:
解决方案
本帖最后由 schumee 于 2015-11-27 17:23:33 编辑
时间: 2024-10-09 06:17:46