search

apache / incubator-streampark

Make stream processing easier! Easy-to-use streaming application development framework and operation platform.
https://streampark.apache.org/
Apache License 2.0
3.91k stars 1.01k forks source link

无法查看stdout #1715

Closed huangkaiyan10 closed 2 years ago

huangkaiyan10 commented 2 years ago

Search before asking

What happened

image

错误日志提示缺少 flink-dist_2.11-1.14.6.jar 、flink-rpc-akka-1.15.2.jar 。

Flink Base Docker Image（172.18.17.235:5000/sms/streamx-flink-1.14.6-2.11-znyw:streamx-flink-1.14.6-2.11-znyw.2022092902） 已经包含了 flink-dist_2.11-1.14.6.jar 、flink-rpc-akka-1.15.2.jar 。

StreamPark Version

1.2.3

Java Version

1.8

Flink Version

1.14.6

Scala Version of Flink

2.11

Error Exception

==============flinkSql==============

 CREATE TABLE datagen (
  f_sequence INT,
  f_random INT,
  f_random_str STRING,
  ts AS localtimestamp,
  WATERMARK FOR ts AS ts
) WITH (
  'connector' = 'datagen',
  -- optional options --
  'rows-per-second' = '5',
  'fields.f_sequence.kind' = 'sequence',
  'fields.f_sequence.start' = '1',
  'fields.f_sequence.end' = '50000',
  'fields.f_random.min' = '1',
  'fields.f_random.max' = '50000',
  'fields.f_random_str.length' = '10'
);
CREATE TABLE print_table (f_sequence INT, f_random INT, f_random_str STRING) WITH ('connector' = 'print');
INSERT INTO
  print_table
select
  f_sequence,
  f_random,
  f_random_str
from
  datagen;

============================

2022-09-29 17:51:49,953 INFO  org.apache.flink.kubernetes.KubernetesResourceManagerDriver  [] - Creating new TaskManager pod with name znyw-base-flink-demo-1-taskmanager-1-1 and resource <1728,1.0>.
2022-09-29 17:51:50,665 INFO  org.apache.flink.kubernetes.KubernetesResourceManagerDriver  [] - Pod znyw-base-flink-demo-1-taskmanager-1-1 is created.
2022-09-29 17:51:50,735 INFO  org.apache.flink.kubernetes.KubernetesResourceManagerDriver  [] - Received new TaskManager pod: znyw-base-flink-demo-1-taskmanager-1-1
2022-09-29 17:51:50,738 INFO  org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Requested worker znyw-base-flink-demo-1-taskmanager-1-1 with resource spec WorkerResourceSpec {cpuCores=1.0, taskHeapSize=384.000mb (402653174 bytes), taskOffHeapSize=0 bytes, networkMemSize=128.000mb (134217730 bytes), managedMemSize=512.000mb (536870920 bytes), numSlots=1}.
2022-09-29 17:52:03,752 INFO  org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Registering TaskManager with ResourceID znyw-base-flink-demo-1-taskmanager-1-1 (akka.tcp://flink@100.123.67.228:6122/user/rpc/taskmanager_0) at ResourceManager
2022-09-29 17:52:03,867 INFO  org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Worker znyw-base-flink-demo-1-taskmanager-1-1 is registered.
2022-09-29 17:52:03,868 INFO  org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Worker znyw-base-flink-demo-1-taskmanager-1-1 with resource spec WorkerResourceSpec {cpuCores=1.0, taskHeapSize=384.000mb (402653174 bytes), taskOffHeapSize=0 bytes, networkMemSize=128.000mb (134217730 bytes), managedMemSize=512.000mb (536870920 bytes), numSlots=1} was requested in current attempt. Current pending count after registering: 0.
2022-09-29 17:52:04,149 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: TableSourceScan(table=[[default_catalog, default_database, datagen]], fields=[f_sequence, f_random, f_random_str]) -> Calc(select=[f_sequence, f_random, f_random_str, LOCALTIMESTAMP() AS ts]) -> WatermarkAssigner(rowtime=[ts], watermark=[ts]) -> Calc(select=[f_sequence, f_random, f_random_str]) -> Sink: Sink(table=[default_catalog.default_database.print_table], fields=[f_sequence, f_random, f_random_str]) (1/1) (f94842d9df3d912db66ed6c5a549734c) switched from SCHEDULED to DEPLOYING.
2022-09-29 17:52:04,408 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: TableSourceScan(table=[[default_catalog, default_database, datagen]], fields=[f_sequence, f_random, f_random_str]) -> Calc(select=[f_sequence, f_random, f_random_str, LOCALTIMESTAMP() AS ts]) -> WatermarkAssigner(rowtime=[ts], watermark=[ts]) -> Calc(select=[f_sequence, f_random, f_random_str]) -> Sink: Sink(table=[default_catalog.default_database.print_table], fields=[f_sequence, f_random, f_random_str]) (1/1) (attempt #0) with attempt id f94842d9df3d912db66ed6c5a549734c to znyw-base-flink-demo-1-taskmanager-1-1 @ 100.123.67.228 (dataPort=42710) with allocation id 074472c96fa7c4f9d7aba21d93267129
2022-09-29 17:52:04,953 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: TableSourceScan(table=[[default_catalog, default_database, datagen]], fields=[f_sequence, f_random, f_random_str]) -> Calc(select=[f_sequence, f_random, f_random_str, LOCALTIMESTAMP() AS ts]) -> WatermarkAssigner(rowtime=[ts], watermark=[ts]) -> Calc(select=[f_sequence, f_random, f_random_str]) -> Sink: Sink(table=[default_catalog.default_database.print_table], fields=[f_sequence, f_random, f_random_str]) (1/1) (f94842d9df3d912db66ed6c5a549734c) switched from DEPLOYING to INITIALIZING.
2022-09-29 17:52:06,320 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: TableSourceScan(table=[[default_catalog, default_database, datagen]], fields=[f_sequence, f_random, f_random_str]) -> Calc(select=[f_sequence, f_random, f_random_str, LOCALTIMESTAMP() AS ts]) -> WatermarkAssigner(rowtime=[ts], watermark=[ts]) -> Calc(select=[f_sequence, f_random, f_random_str]) -> Sink: Sink(table=[default_catalog.default_database.print_table], fields=[f_sequence, f_random, f_random_str]) (1/1) (f94842d9df3d912db66ed6c5a549734c) switched from INITIALIZING to RUNNING.
2022-09-29 17:53:05,423 ERROR org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler [] - Failed to transfer file from TaskExecutor znyw-base-flink-demo-1-taskmanager-1-1.
java.util.concurrent.CompletionException: org.apache.flink.util.FlinkException: The file STDOUT does not exist on the TaskExecutor.
    at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:661) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:646) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:251) ~[?:?]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1387) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.OnComplete.internal(Future.scala:299) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.OnComplete.internal(Future.scala:297) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:25) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) [?:1.8.0_345]
Caused by: 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:2059) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_345]
    at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_345]
2022-09-29 17:53:05,451 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:2059) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_345]
    at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_345]
2022-09-29 17:53:17,210 ERROR org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler [] - Failed to transfer file from TaskExecutor znyw-base-flink-demo-1-taskmanager-1-1.
java.util.concurrent.CompletionException: org.apache.flink.util.FlinkException: The file STDOUT does not exist on the TaskExecutor.
    at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:661) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:646) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:251) ~[?:?]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1387) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.OnComplete.internal(Future.scala:299) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.OnComplete.internal(Future.scala:297) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:25) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) [?:1.8.0_345]
Caused by: 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:2059) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_345]
    at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_345]
2022-09-29 17:53:17,215 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:2059) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_345]
    at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_345]
2022-09-29 17:57:48,314 ERROR org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler [] - Failed to transfer file from TaskExecutor znyw-base-flink-demo-1-taskmanager-1-1.
java.util.concurrent.CompletionException: org.apache.flink.util.FlinkException: The file STDOUT does not exist on the TaskExecutor.
    at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:661) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:646) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:251) ~[?:?]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1387) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.OnComplete.internal(Future.scala:299) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.OnComplete.internal(Future.scala:297) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:25) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) [?:1.8.0_345]
Caused by: 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:2059) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_345]
    at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_345]
2022-09-29 17:57:48,320 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:2059) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_345]
    at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_345]
2022-09-29 17:58:28,540 ERROR org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler [] - Failed to transfer file from TaskExecutor znyw-base-flink-demo-1-taskmanager-1-1.
java.util.concurrent.CompletionException: org.apache.flink.util.FlinkException: The file STDOUT does not exist on the TaskExecutor.
    at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:661) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:646) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:251) ~[?:?]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1387) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.OnComplete.internal(Future.scala:299) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.OnComplete.internal(Future.scala:297) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:25) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) [?:1.8.0_345]
Caused by: 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:2059) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_345]
    at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_345]
2022-09-29 17:58:28,546 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:2059) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_345]
    at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_345]
2022-09-29 18:01:08,010 ERROR org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler [] - Failed to transfer file from TaskExecutor znyw-base-flink-demo-1-taskmanager-1-1.
java.util.concurrent.CompletionException: org.apache.flink.util.FlinkException: The file STDOUT does not exist on the TaskExecutor.
    at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:661) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:646) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:251) ~[?:?]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1387) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) ~[?:1.8.0_345]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) ~[?:1.8.0_345]
    at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.OnComplete.internal(Future.scala:299) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.OnComplete.internal(Future.scala:297) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:25) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) ~[flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) [flink-rpc-akka_08a58fbf-76f9-4af7-87b7-c3411f52e346.jar:1.14.6]
    at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_345]
    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) [?:1.8.0_345]
Caused by: 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:2059) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_345]
    at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_345]
2022-09-29 18:01:08,016 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:2059) ~[flink-dist_2.11-1.14.6.jar:1.14.6]
    at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_345]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_345]
    at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_345]

Screenshots

No response

Are you willing to submit PR?

Code of Conduct

wolfboys commented 2 years ago

please use English.

huangkaiyan10 commented 2 years ago

你的邮件我已经收到。谢谢                                 黄开雁