问答
2021-01-26
来自:开发者社区
flink sql 大量数据时 jvm heap飙升,直至taskmanager挂掉
环境信息 flink version: 1.11jdk version: 1.8.0_231 业务逻辑 使用flink sql注册mysql表,然后进行查询,通过toAppendStream转换为流写入到kudu,发现在flink sql查询期间,由于执行计划中包含cast转换,数据没能达到下一步,一直停止在查询部分,此时 jvm heap极具上升,直到taskmanager oom。
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。
Java开发者
Java开发者成长课堂,课程资料学习,实战案例解析,Java工程师必备词汇等你来~
+关注