Pyflink1.16.1使用UDF会导致JVM Metaspace内存泄漏
版本:python3.8,pyflink1.16.1 集群基于standalone搭建,在上边跑批任务跑了几天,频率比较高,发现taskmanager挂了,之后查询原因定位到是使用了udf的情况就会导致Metaspace内存增加。 然后写了个简单的测试代码印证了下, from pyflink.table.udf import udf @udf(result_ty...
Pyflink JVM Metaspace 内存泄漏定位
Hi, 有个 JVM Metaspace OOM 的问题想请求下帮助,我通过pyflink 提交一些 Batch 任务,任务内执行的是查询 Mysql 的数据统计完写入 Kafka,之后任务就 finished 了。但是发现每次执行任务,JVM Metaspace 的内存会不断增长,即使任务结束后,内存仍然不会释放减少。 这个可能是Flink的哪里设置不对导致的吗?还是代码原因呢? *来自志愿者....
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。
Java开发者
Java开发者成长课堂,课程资料学习,实战案例解析,Java工程师必备词汇等你来~
+关注