I'm running flink locally via ./start-cluster.sh, and submitting my job via ./flink run <class, jar, etc>.
I can attach a debugger <https://cwiki.apache.org/confluence/display/FLINK/Remote+Debugging+of+Flink+Clusters> to the job client process using either: export JVM_ARGS=-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005 or env.java.opts: "-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005" I can step through the main method of my job, but once my program gets to DataStream.execute, the debugger does not follow. That code is now running in a *separate* task executor process, and this is what I would really want to debug. Any tips on how to do this? Thanks, Reggie
