AceMars9527
AceMars9527_个人页
AceMars9527
文章
0
问答
3
视频
0
个人介绍
暂无个人介绍
擅长的技术
暂无更多信息
2024年04月
-
04.26 17:07:00
提交了问题
2024-04-26 17:07:00
-
04.25 15:42:52
回答了问题
2024-04-25 15:42:52
大佬们，请教，pyflink pandas udf如何提高并行度
赞0 踩0 评论0 -
04.09 19:37:47提交了问题
2024-04-09 19:37:47
暂无更多信息
-
提交了问题
2024-04-26
flink批处理任务 137 Killed by external signal该如何解决
-
回答了问题
2024-04-25
大佬们，请教，pyflink pandas udf如何提高并行度
这个问题，我自问自答吧，这两个问题，在使用table的row函数和pandas函数，都会遇到。估计这个是当前版本的问题，我通过将table对象转成datastream对象，然后使用stream的map算子调用row函数，可以指定并行度，处理完成后再转回table对象，这样处理后，这两个问题（并行度问题和map函数前有数据处理问题）都能得到解决
赞0 踩0 评论0 -
提交了问题
2024-04-09
大佬们，请教，pyflink pandas udf如何提高并行度
滑动查看更多
暂无更多信息