I run my application in Flink standalone, but can't find it's sysout in console or FLINK_HOME/log
.
Does anyone know where I can see my application debug log? And how to know which TMs my application run on?
log. dir defines the directory where the Flink logs are saved. It has to be an absolute path. Log location: the logs are local, i.e. they are produced in the machine(s) running the JobManager(s) / Taskmanager(s).
Flink ships with the Log4j API bridge, allowing existing applications that work against Log4j1 classes to continue working.
When running a Flink application in standalone mode on a cluster, everything that is logged to system out or system err goes into the respective local log/
directories.
So for getting the logs, you have to connect (for example using SSH) to the machines running TaskManagers and retrieve the logs from there.
And how to know which TMs my application run on.
The JobManager web interface (running on host:8081 by default) shows where the tasks are deployed to. When the parallelism == number of slots, the tasks usually run on all machines.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With