如何调试Apache Flink？

Question

5

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

- hydronium

2

是的，这是可能的。请搜索“Java 远程调试命令行”。 - Svetlin Zarev

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- hydronium · Accepted Answer

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

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

我创建了一个小的fish shell函数，它包装了Flink作业运行，以便设置正确的参数这里。