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
