Hello, 卓宇: 这个是REST API的报错,说明你在Flink Dashboard中TaskManager页面点击了Stdout选项卡,但对应的TaskManager上访问不到stdout文件,因此报错。该错误不会影响任务的正常运行,可以忽略。
Best, Zhilong On Wed, Apr 20, 2022 at 3:06 PM 陈卓宇 <2572805...@qq.com.invalid> wrote: > 大佬您好: > 小弟想问一下这个异常是什么原因产生的,对生产有何影响,如何消除 > > 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$24(TaskExecutor.java:2064) > ~[flink-dist_2.11-1.13.1.jar:1.13.1] > > at > java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) > ~[?:1.8.0_202] > > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > ~[?:1.8.0_202] > > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > ~[?:1.8.0_202] > > at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_202] > > Caused by: org.apache.flink.util.FlinkException: The file STDOUT does not > exist on the TaskExecutor. > > ... 5 more > > 2022-04-20 14:51:47,370 ERROR > org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler > [] - Unhandled exception. > > org.apache.flink.util.FlinkException: The file STDOUT does not exist on > the TaskExecutor. > > at > org.apache.flink.runtime.taskexecutor.TaskExecutor.lambda$requestFileUploadByFilePath$24(TaskExecutor.java:2064) > ~[flink-dist_2.11-1.13.1.jar:1.13.1] > > at > java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) > ~[?:1.8.0_202] > > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > ~[?:1.8.0_202] > > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > ~[?:1.8.0_202] > > at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_202] > 卓宇 > > >