代码功能:Scala语言编写的spark读取es库数据，读取到的json数据解析后存进临时视图表中，再通过sparksql将临时表中的数据一次性insert进hive表中
代码最终是打包放到ds工具上进行调度执行的，问题出现于某一天任务调度，其他日期调度正常
错误截图:
感觉不只是massage.maxsize大小的问题
急！ERROR: Fileformatwriter:Aborting job
感觉不只是massage.maxsize大小的问题
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
1条回答 默认 最新
问题事件
修改了问题
1月10日-
修改了问题
1月10日
-
创建了问题
1月10日
悬赏问题
- ¥15 oracle集群安装出bug
- ¥15 关于#python#的问题：自动化测试
- ¥20 问题请教！vue项目关于Nginx配置nonce安全策略的问题
- ¥15 教务系统账号被盗号如何追溯设备
- ¥20 delta降尺度方法，未来数据怎么降尺度
- ¥15 c# 使用NPOI快速将datatable数据导入excel中指定sheet，要求快速高效
- ¥15 再不同版本的系统上，TCP传输速度不一致
- ¥15 高德地图2.0 版本点聚合中Marker的位置无法实时更新，如何解决呢？
- ¥15 DIFY API Endpoint 问题。
- ¥20 sub地址DHCP问题