Hello,

I'm trying to debug flink and pyflink job from IDE using mini cluster (local 
mode).

When i doing it in the java flink, everything works like a charm - i can see 
flink mini-cluster logs in the console.

But when i run pyflink job in local mode (through the IDE of by simply calling 
python src/pipeline.py) i can see only logs from python code in the console but 
not a mini-cluster logs. 

Is there a way to enable mini-cluster logs from the python local mode? Maybe i 
can contribute some code for it if you help me where to start.

Reply via email to