我一直在努力扩展apache-flink-python-api，以更好地匹配javaapi，但我在处理的数据类型方面遇到了奇怪的错误。有没有一种方法可以将java调试器（例如intellij idea）附加到flink本身的调试中？
kgqe7b3p1#
感谢svetlinzarev指出了远程java调试。以下是我在提问之前应该发现的一些有用的东西：在ide/debugger/whatever中设置远程调试，例如intellij idea通过在配置中使用适当的远程调试设置env.java.opts来修改apache flink jvm参数或者要调试flink作业运行程序，请设置远程调试并使用 bin/flink 与 JVM_ARGS 设置在您的环境中。确保设置 JVM_ARGS 只为 bin/flink 而不是Flink的工作经理（即。 bin/start-local.sh )否则端口会发生冲突。我已经做了一个小的鱼壳函数来 Package flink job run，以便在这里设置正确的参数。
bin/flink
JVM_ARGS
bin/start-local.sh
1条答案
按热度按时间kgqe7b3p1#
感谢svetlinzarev指出了远程java调试。以下是我在提问之前应该发现的一些有用的东西：
在ide/debugger/whatever中设置远程调试，例如intellij idea
通过在配置中使用适当的远程调试设置env.java.opts来修改apache flink jvm参数
或者要调试flink作业运行程序，请设置远程调试并使用
bin/flink与JVM_ARGS设置在您的环境中。确保设置JVM_ARGS只为bin/flink而不是Flink的工作经理（即。bin/start-local.sh)否则端口会发生冲突。我已经做了一个小的鱼壳函数来 Package flink job run，以便在这里设置正确的参数。