我一直在努力扩展Apache Flink Python API,以更好地匹配Java API,但我遇到了关于我正在处理的数据类型的奇怪错误。有没有办法附加Java调试器(例如Intellij IDEA)来调试Flink本身?
我一直在努力扩展Apache Flink Python API,以更好地匹配Java API,但我遇到了关于我正在处理的数据类型的奇怪错误。有没有办法附加Java调试器(例如Intellij IDEA)来调试Flink本身?
或者,要调试Flink作业运行程序,请设置远程调试并在环境中使用JVM_ARGS
运行作业bin/flink
。请确保仅为bin/flink
设置JVM_ARGS
,而不是Flink作业管理器(即bin/start-local.sh
),否则端口将冲突。
我创建了一个小的fish shell函数,它包装了Flink作业运行,以便设置正确的参数这里。