Job Manager logs

[saksham sapra]

Hi All, 

I am running a job in flink and somehow the job is failing and the task manager is getting out of the pool unknowingly. 

Also some heartbeat timeout exceptions are coming.

Thanks,

Saksham

[Timo Walther]

Hi Saksham,

could you tell us a bit more about your deployement where you run Flink.

This seems to be the root exception:

2020-11-24 11:11:16,296 ERROR
org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler
[] - Failed to transfer file from TaskExecutor
f0dc0ae680e65a97341be79d865f0c03.
java.util.concurrent.CompletionException:
org.apache.flink.util.FlinkException: The file STDOUT does not exist on
the TaskExecutor.
               at
org.apache.flink.runtime.taskexecutor.TaskExecutor.lambda$requestFileUploadByFilePath$25(TaskExecutor.java:1742)
~[flink-dist_2.11-1.11.2.jar:1.11.2]
               at
java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source)
~[?:?]
               at
java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
               at
java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?]
               at java.lang.Thread.run(Unknown Source) ~[?:?]
Caused by: org.apache.flink.util.FlinkException: The file STDOUT does
not exist on the TaskExecutor.
               ... 5 more

It crashes the task managers. I would check whether they have write
access? Or is the directory misconfigured?

Regards,
Timo


On 24.11.20 12:50, saksham sapra wrote:
> Hi All,
>
> I am running a job in flink and somehow the job is failing and the task
> manager is getting out of the pool unknowingly.
>
> Also some heartbeat timeout exceptions are coming.
>
> Thanks,
> Saksham