如何调试flink应用程序以进行内存和垃圾回收?

5t7ly7z5  于 2021-06-25  发布在  Flink
关注(0)|答案(1)|浏览(449)

我使用的是flink1.1.4,并添加了 flink-conf.yaml 内存调试的配置参数,如内存和性能调试中所述:

taskmanager.debug.memory.startLogThread: true
taskmanager.debug.memory.logIntervalMs: 1000

重新启动flink之后,我看到新的参数被添加到作业管理器界面,但是我看不到任何新的日志。
你知道我遗漏了什么吗?

tjrkku2a

tjrkku2a1#

看来这在邮件列表中已经解决了
关键摘录,包括一个确认准确设置的摘录已成功测试:
这正是正确的方法。日志记录必须至少为info,并且参数“taskmanager.debug.memory.startlogthread”必须设置为true。日志输出应该在“org.apache.flink.runtime.taskmanager.taskmanager”下。
您在日志中看到该类的其他输出了吗?
确保在更改配置文件后重新启动taskmanager进程。
其他人只是使用了内存日志与确切描述的设置-它的工作。
可能有些混乱,您可能查看了错误的日志文件,或者可能在其他配置中设置了a值。。。
如何启动flink群集?如果它是一个独立的集群,并且您不使用共享目录,那么您将在运行taskmanager的计算机上找到taskmanager的日志。如果使用yarn,则可以激活日志聚合,以便在作业完成后轻松检索日志。

相关问题