采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
老师请看上面的代码,此处age如果是int类型就会报错,改成String类型就可以正常输出结果,错误日志如下图
此处加上trim(),运行完美通过
那是因为有脏数据,你在梳理过程中要进行try catch才行
老师,我试了,把maven删了重新去官网下了个新3.54的,maven里面scala和spark的版本号也跟你课程上的一样,也重新配置了仓库,确定没有脏数据,代码也重新写了,还是存在同样的问题
肯定不是你说的问题!你如果用的是上课的多的数据的,肯定就是有脏数据,100%有!!!!因为有小伙伴已经遇到了,肯定需要过滤的
感谢老师深夜回复,已经找到原因了,在转换之前需要在line(1)后面加trim()去掉空格
登录后可查看更多问答,登录/注册
快速转型大数据:Hadoop,Hive,SparkSQL步步为赢
2.0k 6
2.1k 6
2.2k 1
1.5k 21
1.8k 18
购课补贴联系客服咨询优惠详情
慕课网APP您的移动学习伙伴
扫描二维码关注慕课网微信公众号