?????? The file STDOUT does not exist on the TaskExecutor ????

?????? Wed, 20 Apr 2022 01:57:29 -0700

??????????


??????


&nbsp;




------------------&nbsp;????????&nbsp;------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<zhlongh...@gmail.com&gt;;
????????:&nbsp;2022??4??20??(??????) ????4:50
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Re: The file STDOUT does not exist on the TaskExecutor ????



Hello, ??????

??????REST API????????????????Flink
Dashboard??TaskManager??????????Stdout????????????????TaskManager??????????stdout????????????????????????????????????????????????????????

Best,
Zhilong

On Wed, Apr 20, 2022 at 3:06 PM ?????? <2572805...@qq.com.invalid&gt; wrote:

&gt; ??????????
&gt; &amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; 
??????????????????????????????????????????????????????????????
&gt;
&gt; java.util.concurrent.CompletionException:
&gt; org.apache.flink.util.FlinkException: The file STDOUT does not exist on the
&gt; TaskExecutor.
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
org.apache.flink.runtime.taskexecutor.TaskExecutor.lambda$requestFileUploadByFilePath$24(TaskExecutor.java:2064)
&gt; ~[flink-dist_2.11-1.13.1.jar:1.13.1]
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590)
&gt; ~[?:1.8.0_202]
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
&gt; ~[?:1.8.0_202]
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
&gt; ~[?:1.8.0_202]
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_202]
&gt;
&gt; Caused by: org.apache.flink.util.FlinkException: The file STDOUT does not
&gt; exist on the TaskExecutor.
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ... 5 more
&gt;
&gt; 2022-04-20 14:51:47,370 ERROR
&gt; 
org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler
&gt; [] - Unhandled exception.
&gt;
&gt; org.apache.flink.util.FlinkException: The file STDOUT does not exist on
&gt; the TaskExecutor.
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
org.apache.flink.runtime.taskexecutor.TaskExecutor.lambda$requestFileUploadByFilePath$24(TaskExecutor.java:2064)
&gt; ~[flink-dist_2.11-1.13.1.jar:1.13.1]
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590)
&gt; ~[?:1.8.0_202]
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
&gt; ~[?:1.8.0_202]
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
&gt; ~[?:1.8.0_202]
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_202]
&gt; ????
&gt;
&gt;
&gt; &amp;nbsp;

?????? The file STDOUT does not exist on the TaskExecutor ????

回复