如何调试 Apache Flink？
How do I debug Apache Flink?
我一直致力于扩展 Apache Flink Python API 以更好地匹配 Java API，但我遇到了关于数据类型的奇怪错误我正在努力。有没有办法附加一个 Java 调试器（例如 Intellij IDEA）来调试 Flink 本身？
感谢 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）设置，否则端口会发生冲突。
我做了一个小鱼 shell 包装 Flink 作业的函数 运行 以便设置正确的参数 here.
我一直致力于扩展 Apache Flink Python API 以更好地匹配 Java API，但我遇到了关于数据类型的奇怪错误我正在努力。有没有办法附加一个 Java 调试器（例如 Intellij IDEA）来调试 Flink 本身？
感谢 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）设置，否则端口会发生冲突。
我做了一个小鱼 shell 包装 Flink 作业的函数 运行 以便设置正确的参数 here.