采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
能想到这里没有关闭,非常不错的。你是整个学习课程的人中第一个提出来的,很欣慰。
这里用完是需要关闭的,只要判断partition中没有数据了就可以手工给他关掉,加个if判断就OK了
使用并行度为2 一般是在这个分区执行完后将连接关闭,但是多并行度下操作这个链接会报 B cannot be cast to java.lang.Long ,我也是之前遇到过这个问题,不知道怎么处理,就刚好参考了下您的代码,能麻烦具体告诉我这块该怎么合理关闭这个链接,这个判断part中没法判断有没有数据呀,这个不关闭的话 工作场景中还是比较麻烦的
你这个问题和并行度没有关系。 B cannot be cast to java.lang.Long这个错是你的数据有问题,B是个字符串呢咋能转成Long呢? 有啥麻烦的?代码的最后就加一个判断partition的迭代器中是否还有数据就OK了
登录后可查看更多问答,登录/注册
大数据生态圈实用框架(Spark/Hbase/Redis/Hadoop)整合应用及调优
1.3k 21
885 11
1.7k 11
1.1k 11
1.4k 11