debugging - 如何调试 Apache Flink？

Question

我一直致力于扩展 Apache Flink Python API 以更好地匹配 Java API，但我收到了关于我正在处理的数据类型的奇怪错误。有没有办法附加 Java 调试器(例如 Intellij IDEA)来调试 Flink 本身？

Answer 1

感谢 Svetlin Zarev用于指出远程 Java 调试。以下是我在提问之前应该找到的一些有用的东西:

在 IDE/debugger/whatever 中设置远程调试，例如为 IntelliJ IDEA

通过 setting env.java.opts in the configuration 修改 Apache Flink JVM 参数使用适当的设置进行远程调试

或者要调试 Flink 作业运行程序，请使用 bin/flink 设置远程调试并运行作业。与 JVM_ARGS设置在您的环境中。确保设置 JVM_ARGS仅适用于 bin/flink而不是用于 Flink 作业管理器(即 bin/start-local.sh )，否则端口会发生冲突。

我制作了一个小鱼 shell 函数来包装 Flink 作业运行，以便设置正确的参数 here .