退订
退订
Pyflink JVM Metaspace 内存泄漏定位
Hi， 有个 JVM Metaspace OOM 的问题想请求下帮助，我通过pyflink 提交一些 Batch 任务，任务内执行的是查询 Mysql 的数据统计完写入 Kafka，之后任务就 finished 了。但是发现每次执行任务，JVM Metaspace 的内存会不断增长，即使任务结束后，内存仍然不会释放减少。 这个可能是Flink的哪里设置不对导致的吗？还是代码原因呢？ JVM Met
Pyflink 提交 Batch 任务后报错 “Failed to execute sql”
Hi， 请教一个问题： 我近期在使用Pyflink，有个问题经常会出现，就是在提交Batch任务的时候，经常会报 “Failed to execute sql” 的错误，终端输出的具体错误信息如下： Traceback (most recent call last): File "/opt/flink/ha_store/test/device_status_statistics.py", line
