如何调试 Apache Flink？答案

【问题标题】：How do I debug Apache Flink?如何调试 Apache Flink？
【发布时间】：2016-06-06 13:47:25
【问题描述】：

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

【问题讨论】：

是的，这是可能的。谷歌“Java 远程调试命令行”

标签： debugging apache-flink

【解决方案1】：

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

在 IDE/debugger/whatever 中设置远程调试，例如对于IntelliJ IDEA
使用适当的远程调试设置通过setting env.java.opts in the configuration 修改 Apache Flink JVM 参数

或调试 Flink 作业运行器，设置远程调试并在您的环境中使用 bin/flink 和 JVM_ARGS 运行作业。确保为bin/flink 设置JVM_ARGS 而不是为Flink 作业管理器（即bin/start-local.sh）设置bin/start-local.sh，否则端口会冲突。

我制作了一个封装 Flink 作业运行的小鱼壳函数，以便设置正确的参数 here。

【讨论】：