Thanks for help, I’ll look into it :)

Two more questions:

Is there a way to configure this path? For example to write logs to a file in 
the working dir?

And is there a way to redirect logst from file to stdout?

On 9 Nov 2021, at 09:00, Dian Fu 
<dian0511...@gmail.com<mailto:dian0511...@gmail.com>> wrote:

Hi,

The logs should appear in the log file of the TaskManger and you could find it 
under directory $PYTHON_INSTALLATION_DIR/site-packages/pyflink/log/

Regards,
Dian

On Mon, Nov 8, 2021 at 10:53 PM Роман VVvKamper 
<vvvkam...@deeplay.io<mailto:vvvkam...@deeplay.io>> wrote:
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