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>
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