当前位置: 首页 > news >正文

flink1.13报错:The file STDOUT does not exist on the TaskExecutor

在这里插入图片描述


1.执行环境

flink1.13
jdk8


2.日志内容

2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: web.submit.enable, false
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: oceanus.job.info, {“jobSerialId”:“cql-4i3wk3w8”}
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.jobmanager.service-account, flink
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: blob.server.port, 6124
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: job.version-id, 28
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: metrics.reporter.promgateway.user, 1304768263
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.savepoints.dir, cosn://zlfz-oceanus-1304768263/1304768263/100025221053/cql-4i3wk3w8/32/flink-savepoints
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.taskmanager.cpu, 2.000000
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.user-dependency-file-config, []
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.maximum-failed-containers, 65535
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability.jobmanager.port, 6123
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.job-status-listeners.com.tencent.cloud.tstream.flink.OceanusEventListener.info, {“jobSerialId”:“cql-4i3wk3w8”,“jobRuntimeId”:“495920”}
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.application.main, com.kungeek.rtdw.ads.AdsTaxIndicators
2022-08-29 17:28:35.789 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: flink.partition-discovery.interval-millis, 30000
2022-08-29 17:28:35.790 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: client.timeout, 1800s
2022-08-29 17:28:35.790 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.internal.remote.jar.dependencies, /user/user_00/.flink/cql-4i3wk3w8-495920/1661765295460/flink-task-rtdw-tax-1.0-SNAPSHOT-jar-with-dependencies.jar
2022-08-29 17:28:35.790 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.target, kubernetes-application
2022-08-29 17:28:35.790 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.internal.remote.jar.ship-to-system, /user/user_00/.flink/cql-4i3wk3w8-495920/1661765295460/systemShipFiles/pool-1-thread-6-1661765290835-flink-connector-clickhouse-1.13.2-SNAPSHOT.jar;/user/user_00/.flink/cql-4i3wk3w8-495920/1661765295460/systemShipFiles/pool-1-thread-9-1661765290993-flink-task-rtdw-udf-1.0-SNAPSHOT-jar-with-dependencies.jar
2022-08-29 17:28:35.790 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.attached, true
2022-08-29 17:28:35.790 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability, zookeeper
2022-08-29 17:28:35.790 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: metrics.reporter.oceanus.interval, 60 SECONDS
2022-08-29 17:28:35.790 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.shutdown-on-attached-exit, false
2022-08-29 17:28:35.790 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: pipeline.jars, local:///var/flink-data/flink-jars/flink-task-rtdw-tax-1.0-SNAPSHOT-jar-with-dependencies.jar
2022-08-29 17:28:35.790 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: restart-strategy, fixed-delay
2022-08-29 17:28:35.790 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.java.opts.taskmanager, -XX:ErrorFile=/tmp/taskmanager.err
2022-08-29 17:28:35.790 [main] INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.dir, cosn://zlfz-oceanus-1304768263/1304768263/100025221053/cql-4i3wk3w8/32/flink-checkpoints
2022-08-29 17:28:35.793 [main] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager at akka://flink/user/rpc/resourcemanager_0 .
2022-08-29 17:28:35.807 [main] INFO org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - Starting DefaultLeaderElectionService with ZooKeeperLeaderElectionDriver{leaderPath=‘/leader/dispatcher_lock’}.
2022-08-29 17:28:35.807 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Starting the resource manager.
2022-08-29 17:28:35.809 [main] INFO org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with ZookeeperLeaderRetrievalDriver{retrievalPath=‘/leader/resource_manager_lock’}.
2022-08-29 17:28:35.809 [main] INFO org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Starting DefaultLeaderRetrievalService with ZookeeperLeaderRetrievalDriver{retrievalPath=‘/leader/dispatcher_lock’}.
2022-08-29 17:28:35.859 [main-EventThread] INFO org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner [] - DefaultDispatcherRunner was granted leadership with leader id de4b7fe5-8906-4117-9766-79fd9ad96663. Creating new DispatcherLeaderProcess.
2022-08-29 17:28:35.883 [main-EventThread] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Start SessionDispatcherLeaderProcess.
2022-08-29 17:28:35.887 [cluster-io-thread-1] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Recover all persisted job graphs.
2022-08-29 17:28:35.890 [cluster-io-thread-1] INFO org.apache.flink.runtime.jobmanager.DefaultJobGraphStore [] - Retrieved job ids [] from ZooKeeperStateHandleStore{namespace=‘flink/cql-4i3wk3w8-495920/jobgraphs’}
2022-08-29 17:28:35.890 [cluster-io-thread-1] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Successfully recovered 0 persisted job graphs.
2022-08-29 17:28:35.896 [cluster-io-thread-1] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/rpc/dispatcher_1 .
2022-08-29 17:28:35.909 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.client.ClientUtils [] - Starting program (detached: false)
2022-08-29 17:28:35.990 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend [] - Using predefined options: DEFAULT.
2022-08-29 17:28:35.991 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend [] - Using default options factory: DefaultConfigurableOptionsFactory{configuredOptions={}}.
2022-08-29 17:28:36.274 [flink-akka.actor.default-dispatcher-4] WARN org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Property [transaction.timeout.ms] not specified. Setting it to 3600000 ms
2022-08-29 17:28:36.394 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator [] - User did not set CheckpointRetentionPolicy, CheckpointRetentionPolicy is set to RETAIN_ON_FAILURE by Oceanus
2022-08-29 17:28:36.398 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.client.deployment.application.executors.EmbeddedExecutor [] - Job 00000000000000000000000000000000 is submitted.
2022-08-29 17:28:36.398 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.client.deployment.application.executors.EmbeddedExecutor [] - Submitting Job with JobId=00000000000000000000000000000000.
2022-08-29 17:28:37.090 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.kubernetes.KubernetesResourceManagerDriver [] - Recovered 0 pods from previous attempts, current attempt id is 1.
2022-08-29 17:28:37.091 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Recovered 0 workers from previous attempt.
2022-08-29 17:28:37.091 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - Starting DefaultLeaderElectionService with ZooKeeperLeaderElectionDriver{leaderPath=‘/leader/resource_manager_lock’}.
2022-08-29 17:28:37.165 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - ResourceManager akka.tcp://flink@9.166.1.158:6123/user/rpc/resourcemanager_0 was granted leadership with fencing token 9b027605d8adb4c14c678f28e6e4429a
2022-08-29 17:28:37.896 [BLOB connection for /127.0.0.1:57750] INFO org.apache.hadoop.fs.CosNFSDataOutputStream [] - The consistency checker is enabled.
2022-08-29 17:28:39.514 [BLOB connection for /127.0.0.1:57750] INFO org.apache.hadoop.fs.CosNFSDataOutputStream [] - Upload the last part. key: /state/ha/cql-4i3wk3w8-495920/blob/job_00000000000000000000000000000000/blob_p-04eb58213107de8176f1d0b822d4c6de53f6b34d-55263fe9ac5688ed640724a5109f1972, blockId: [19], blockWritten: [1986219]
2022-08-29 17:28:39.668 [BLOB connection for /127.0.0.1:57750] INFO org.apache.hadoop.fs.CosNFSDataOutputStream [] - Waiting for finish part uploads…
2022-08-29 17:28:39.839 [BLOB connection for /127.0.0.1:57750] INFO org.apache.hadoop.fs.CosNFSDataOutputStream [] - Upload the key [/state/ha/cql-4i3wk3w8-495920/blob/job_00000000000000000000000000000000/blob_p-04eb58213107de8176f1d0b822d4c6de53f6b34d-55263fe9ac5688ed640724a5109f1972] successfully. check message: File verification succeeded. expected length: 152981163, real length: 152981163.
2022-08-29 17:28:39.841 [flink-akka.actor.default-dispatcher-15] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Received JobGraph submission 00000000000000000000000000000000 (Flink Streaming Job).
2022-08-29 17:28:39.842 [flink-akka.actor.default-dispatcher-15] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Submitting job 00000000000000000000000000000000 (Flink Streaming Job).
2022-08-29 17:28:39.937 [flink-akka.actor.default-dispatcher-15] INFO org.apache.hadoop.fs.CosNFSDataOutputStream [] - The consistency checker is enabled.
2022-08-29 17:28:39.949 [flink-akka.actor.default-dispatcher-15] INFO org.apache.hadoop.fs.CosNFSDataOutputStream [] - Single file upload… key: /state/ha/cql-4i3wk3w8-495920/submittedJobGraph1d6cc4f11f50, blockId: 0, blockWritten: 40920.
2022-08-29 17:28:40.061 [flink-akka.actor.default-dispatcher-15] INFO org.apache.hadoop.fs.CosNFSDataOutputStream [] - Upload the key [/state/ha/cql-4i3wk3w8-495920/submittedJobGraph1d6cc4f11f50] successfully. check message: File verification succeeded. expected length: 40920, real length: 40920.
2022-08-29 17:28:40.070 [flink-akka.actor.default-dispatcher-15] INFO org.apache.flink.runtime.jobmanager.DefaultJobGraphStore [] - Added JobGraph(jobId: 00000000000000000000000000000000) to ZooKeeperStateHandleStore{namespace=‘flink/cql-4i3wk3w8-495920/jobgraphs’}.
2022-08-29 17:28:40.080 [flink-akka.actor.default-dispatcher-15] INFO org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] - Starting DefaultLeaderElectionService with ZooKeeperLeaderElectionDriver{leaderPath=‘/leader/00000000000000000000000000000000/job_manager_lock’}.
2022-08-29 17:28:40.112 [jobmanager-future-thread-1] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/rpc/jobmanager_2 .
2022-08-29 17:28:40.118 [jobmanager-future-thread-1] INFO org.apache.flink.runtime.jobmaster.JobMaster [] - Initializing job Flink Streaming Job (00000000000000000000000000000000).
2022-08-29 17:28:40.128 [jobmanager-future-thread-1] INFO com.tencent.cloud.tstream.flink.OceanusEventListener [] - conf: {metrics.reporter.promgateway.interval=60 SECONDS, env.java.opts=-verbose:gc -server -XX:+PrintGCDetails -XX:+PrintGCTimeStamps -XX:ActiveProcessorCount=4 -Dlog4j2.formatMsgNoLookups=true, job.running-order-id=32, jobmanager.rpc.address=9.166.1.158, taskmanager.memory.task.off-heap.size=1024m, taskmanager.memory.jvm-metaspace.size=1024m, metrics.reporter.promgateway.groupingKey=cluster_id=cluster-7whrcxmp;instance_id=cql-4i3wk3w8;version_id=28;runtime_id=495920, oceanus.watchdog.url=http://watchdog-service.oceanus:8600/, kubernetes.container-start-command-template=%java% -Duser.timezone=GMT+08 %classpath% %jvmmem% %jvmopts% %logging% %class% %args%, pipeline.max-parallelism=2048, metrics.latency.granularity=single, metrics.reporter.barad.extraKeys={“tjob_id_num”:“16076”,“tjob_id”:“cql-4i3wk3w8”,“tjob_app_id”:“1304768263”,“tjob_runtime_id”:“495920”,“tjob_config_id”:“57258”}, metrics.reporters=barad,oceanus, cluster.group.serial-id=cluster-7whrcxmp, metrics.reporter.oceanus.randomJobNameSuffix=false, execution.checkpointing.tolerable-failed-checkpoints=5, state.backend.rocksdb.localdir=/data/rocksdb, job.runtime-id=495920, web.tmpdir=/tmp/flink-web-0192e281-7efb-4e3a-9d02-8889858c3a7a, $internal.pipeline.job-id=00000000000000000000000000000000, kubernetes.jobmanager.cpu=2.000000, fs.hdfs.hadoopconf=/opt/cluster-admin/hadoop, taskmanager.memory.managed.fraction=0.1, state.backend=rocksdb, metrics.reporter.barad.class=com.tencent.cloud.tstream.flink.BaradReporter, metrics.reporter.oceanus.class=org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporter, kubernetes.jobmanager.annotations=‘tke.cloud.tencent.com/networks:tke-bridge,tke-direct-eni,tke-route’,‘tke.cloud.tencent.com/cross-tenant-eni-enable:true’, state.checkpoints.num-retained=2, jobmanager.memory.jvm-overhead.min=858993472b, kubernetes.jobmanager.labels=appId:1304768263,ownerUin:100017415366,creatorUin:100025221053,jConfId:57258,requestId:47b1f5fd-9abb-4b6d-9f69-babc1483a51d,jobSerialId:cql-4i3wk3w8,jobRunningOrderId:32,logCollect:6e7e31aa-f6df-469d-80ad-51adb1719071,logCollect-cql-4i3wk3w8:cql-4i3wk3w8, metrics.reporter.oceanus.jobName=cql-4i3wk3w8, execution.savepoint.ignore-unclaimed-state=false, metrics.reporter.oceanus.host=metric-provider-service.oceanus, kubernetes.container.image=ccr.ccs.tencentyun.com/oceanus-release/flink-k8s:flink-1.13-6.4.1-20220706, yarn.application-attempts=20, containerized.taskmanager.env.JVM_ARGS=-Duser.timezone=GMT+08, metrics.reporter.promgateway.randomJobNameSuffix=true, kubernetes.rest-service.exposed.type=ClusterIP, akka.ask.timeout=60s, jobmanager.checkpoint-listeners.com.tencent.cloud.tstream.flink.OceanusCheckpointListener.url=http://watchdog-service.oceanus:8600/report/checkpoint/, state.backend.fs.checkpointdir=cosn://zlfz-oceanus-1304768263/1304768263/100025221053/cql-4i3wk3w8/32/flink-checkpoints, classloader.resolve-order=parent-first, web.timeout=1000000, restart-strategy.fixed-delay.attempts=50, metrics.latency.interval=30000, jobmanager.memory.process.size=8192m, taskmanager.rpc.port=6122, kubernetes.internal.enable.init.container=true, kubernetes.ship-directories=/data/workspace/1304768263/100025221053/runtime/cql-4i3wk3w8/495920/shipFiles, internal.cluster.execution-mode=NORMAL, jobmanager.job-status-listeners.com.tencent.cloud.tstream.flink.OceanusEventListener.url=http://watchdog-service.oceanus:8600/report/job/, jobmanager.checkpoint-listeners.com.tencent.cloud.tstream.flink.OceanusCheckpointListener.info={“jobSerialId”:“cql-4i3wk3w8”,“jobRuntimeId”:“495920”,“jobId”:“16076”}, metrics.reporter.oceanus.port=8421, jobmanager.memory.jvm-metaspace.size=268435456b, metrics.reporter.oceanus.deleteOnShutdown=false, metrics.reporter.oceanus.enableMetricWhiteList=true, jobmanager.checkpoint-listeners=com.tencent.cloud.tstream.flink.OceanusCheckpointListener, metrics.reporter.promgateway.jobName=AdsTaxIndicators, high-availability.cluster-id=cql-4i3wk3w8-495920, jobmanager.job-status-listeners=com.tencent.cloud.tstream.flink.OceanusEventListener, kubernetes.cluster-id=cql-4i3wk3w8-495920, high-availability.zookeeper.path.root=/flink, metrics.reporter.promgateway.class=org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporter, metrics.reporter.barad.region=cls-104iwrq5, high-availability.storageDir=cosn://zlfz-oceanus-1304768263/state/ha, rest.bind-port=8081, jobmanager.retrieve-taskmanager-hostname=false, parallelism.default=1, kubernetes.namespace=default, pipeline.classpaths=[file:/data/workspace/1304768263/100025221053/runtime/cql-4i3wk3w8/495920/shipFiles/pool-1-thread-6-1661765290835-flink-connector-clickhouse-1.13.2-SNAPSHOT.jar, file:/data/workspace/1304768263/100025221053/runtime/cql-4i3wk3w8/495920/shipFiles/pool-1-thread-9-1661765290993-flink-task-rtdw-udf-1.0-SNAPSHOT-jar-with-dependencies.jar, file:opt/flink-1.13.6/usrlib/pool-1-thread-6-1661765290835-flink-connector-clickhouse-1.13.2-SNAPSHOT.jar, file:opt/flink-1.13.6/usrlib/pool-1-thread-9-1661765290993-flink-task-rtdw-udf-1.0-SNAPSHOT-jar-with-dependencies.jar], taskmanager.memory.process.size=8192m, flink.hadoop.hadoop.security.authentication=simple, kubernetes.internal.jobmanager.entrypoint.class=org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint, kubernetes.rest-service.annotations=service.kubernetes.io/qcloud-loadbalancer-internal-subnetid:subnet-b9pzagfz, jobmanager.memory.off-heap.size=134217728b, state.backend.incremental=true, metrics.latency.history-size=30, jobmanager.rpc.port=6123, kubernetes.container.image.pull-policy=IfNotPresent, containerized.master.env.JVM_ARGS=-Duser.timezone=GMT+08, high-availability.zookeeper.quorum=zookeeper-0.zookeeper-headless.oceanus.svc.cluster.local:2181,zookeeper-1.zookeeper-headless.oceanus.svc.cluster.local:2181,zookeeper-2.zookeeper-headless.oceanus.svc.cluster.local:2181, restart-strategy.fixed-delay.delay=10s, kubernetes.taskmanager.annotations=‘tke.cloud.tencent.com/networks:tke-bridge,tke-direct-eni,tke-route’,‘tke.cloud.tencent.com/cross-tenant-eni-enable:true’, kubernetes.taskmanager.labels=appId:1304768263,ownerUin:100017415366,creatorUin:100025221053,jConfId:57258,requestId:47b1f5fd-9abb-4b6d-9f69-babc1483a51d,jobSerialId:cql-4i3wk3w8,jobRunningOrderId:32,logCollect:6e7e31aa-f6df-469d-80ad-51adb1719071,logCollect-cql-4i3wk3w8:cql-4i3wk3w8, web.submit.enable=false, oceanus.job.info={“jobSerialId”:“cql-4i3wk3w8”}, rest.address=9.166.1.158, kubernetes.jobmanager.service-account=flink, jobmanager.memory.jvm-overhead.max=858993472b, blob.server.port=6124, job.version-id=28, metrics.reporter.promgateway.user=1304768263, state.savepoints.dir=cosn://zlfz-oceanus-1304768263/1304768263/100025221053/cql-4i3wk3w8/32/flink-savepoints, kubernetes.taskmanager.cpu=2.000000, kubernetes.user-dependency-file-config=[], yarn.maximum-failed-containers=65535, taskmanager.numberOfTaskSlots=1, high-availability.jobmanager.port=6123, jobmanager.job-status-listeners.com.tencent.cloud.tstream.flink.OceanusEventListener.info={“jobSerialId”:“cql-4i3wk3w8”,“jobRuntimeId”:“495920”}, KaTeX parse error: Expected 'EOF', got '}' at position 1172: …ink-checkpoints}̲ 2022-08-29 17:…requestFileUploadByFilePath 24 ( T a s k E x e c u t o r . j a v a : 2064 )   [ f l i n k − d i s t 2 . 11 − 1.13.6. j a r : 1.13.6 ] a t j a v a . u t i l . c o n c u r r e n t . C o m p l e t a b l e F u t u r e 24(TaskExecutor.java:2064) ~[flink-dist_2.11-1.13.6.jar:1.13.6] at java.util.concurrent.CompletableFuture 24(TaskExecutor.java:2064) [flinkdist2.111.13.6.jar:1.13.6]atjava.util.concurrent.CompletableFutureAsyncSupply.run(CompletableFuture.java:1590) ~[?:1.8.0_232]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_232]
at java.util.concurrent.ThreadPoolExecutor W o r k e r . r u n ( T h r e a d P o o l E x e c u t o r . j a v a : 624 )   [ ? : 1.8. 0 2 32 ] a t j a v a . l a n g . T h r e a d . r u n ( T h r e a d . j a v a : 748 )   [ ? : 1.8. 0 2 32 ] C a u s e d b y : o r g . a p a c h e . f l i n k . u t i l . F l i n k E x c e p t i o n : T h e f i l e S T D O U T d o e s n o t e x i s t o n t h e T a s k E x e c u t o r . . . . 5 m o r e 2022 − 08 − 3011 : 17 : 08.425 [ f l i n k − a k k a . a c t o r . d e f a u l t − d i s p a t c h e r − 3 ] E R R O R o r g . a p a c h e . f l i n k . r u n t i m e . r e s t . h a n d l e r . t a s k m a n a g e r . T a s k M a n a g e r S t d o u t F i l e H a n d l e r [ ] − U n h a n d l e d e x c e p t i o n . o r g . a p a c h e . f l i n k . u t i l . F l i n k E x c e p t i o n : T h e f i l e S T D O U T d o e s n o t e x i s t o n t h e T a s k E x e c u t o r . a t o r g . a p a c h e . f l i n k . r u n t i m e . t a s k e x e c u t o r . T a s k E x e c u t o r . l a m b d a Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_232] at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_232] Caused by: org.apache.flink.util.FlinkException: The file STDOUT does not exist on the TaskExecutor. ... 5 more 2022-08-30 11:17:08.425 [flink-akka.actor.default-dispatcher-3] 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 Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0232]atjava.lang.Thread.run(Thread.java:748) [?:1.8.0232]Causedby:org.apache.flink.util.FlinkException:ThefileSTDOUTdoesnotexistontheTaskExecutor....5more2022083011:17:08.425[flinkakka.actor.defaultdispatcher3]ERRORorg.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler[]Unhandledexception.org.apache.flink.util.FlinkException:ThefileSTDOUTdoesnotexistontheTaskExecutor.atorg.apache.flink.runtime.taskexecutor.TaskExecutor.lambdarequestFileUploadByFilePath 24 ( T a s k E x e c u t o r . j a v a : 2064 )   [ f l i n k − d i s t 2 . 11 − 1.13.6. j a r : 1.13.6 ] a t j a v a . u t i l . c o n c u r r e n t . C o m p l e t a b l e F u t u r e 24(TaskExecutor.java:2064) ~[flink-dist_2.11-1.13.6.jar:1.13.6] at java.util.concurrent.CompletableFuture 24(TaskExecutor.java:2064) [flinkdist2.111.13.6.jar:1.13.6]atjava.util.concurrent.CompletableFutureAsyncSupply.run(CompletableFuture.java:1590) ~[?:1.8.0_232]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_232]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_232]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_232]


3.报错内容分析

2022-08-30 11:17:08.425 [flink-akka.actor.default-dispatcher-3] 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 

该报错主要是找不到STDOUT文件,原因是程序中没有sout输出,当你去web-ui点击stdout目录,就会报一个这儿样的接口请求错误,并不影响程序运行,可忽略。
在这里插入图片描述


4.解决方案

建议忽略
如果一定要修复,提供以下方案:
1.修复flink runtime源码
2.如果没有sout输出,不要点击stdout目录
3.随便加一点sout输出在程序里

相关文章:

  • java计算机毕业设计口腔医院网站源码+数据库+系统+lw文档+mybatis+运行部署
  • 比较两个文本,找出在另一文本中出现过的串并换某种格式输出
  • Windows下安装虚拟环境
  • SpringMVC之注解驱动的控制器
  • Flask--路由配置
  • Linux定时器
  • iNFTnews | 一词解答区块链技术普及的制胜关键
  • 京准,PTP时间同步服务器在运营商通信网应用
  • 判断数组类型的方法(Array.isArray)以及Math数字对象
  • zemax---Tangential plane, meridian plane and sagittal plane(切线面,子午面与弧矢面)(完结)
  • Java配置42-配置redis高可用(sentinel监控)
  • 共话龙蜥:中国操作系统到底有没有角力世界舞台的实力?
  • vue独立提供模板下载功能
  • 怎么判断MES系统好不好?MES又是如何帮企业省钱的?
  • 数据治理:为什么不见BI作关联分析
  • 【Under-the-hood-ReactJS-Part0】React源码解读
  • 【跃迁之路】【733天】程序员高效学习方法论探索系列(实验阶段490-2019.2.23)...
  • avalon2.2的VM生成过程
  • create-react-app做的留言板
  • js中forEach回调同异步问题
  • Linux gpio口使用方法
  • mysql 数据库四种事务隔离级别
  • nodejs调试方法
  • Vue 动态创建 component
  • 百度贴吧爬虫node+vue baidu_tieba_crawler
  • 编写高质量JavaScript代码之并发
  • 聚簇索引和非聚簇索引
  • 免费小说阅读小程序
  • 人脸识别最新开发经验demo
  • 如何使用 OAuth 2.0 将 LinkedIn 集成入 iOS 应用
  • 通过来模仿稀土掘金个人页面的布局来学习使用CoordinatorLayout
  • 在GitHub多个账号上使用不同的SSH的配置方法
  • # Pytorch 中可以直接调用的Loss Functions总结:
  • ### Cause: com.mysql.jdbc.exceptions.jdbc4.MySQLTr
  • #100天计划# 2013年9月29日
  • #我与Java虚拟机的故事#连载04:一本让自己没面子的书
  • $ is not function   和JQUERY 命名 冲突的解说 Jquer问题 (
  • (02)vite环境变量配置
  • (附源码)计算机毕业设计ssm基于Internet快递柜管理系统
  • (介绍与使用)物联网NodeMCUESP8266(ESP-12F)连接新版onenet mqtt协议实现上传数据(温湿度)和下发指令(控制LED灯)
  • (七)Knockout 创建自定义绑定
  • (三分钟了解debug)SLAM研究方向-Debug总结
  • (三维重建学习)已有位姿放入colmap和3D Gaussian Splatting训练
  • (十二)python网络爬虫(理论+实战)——实战:使用BeautfulSoup解析baidu热搜新闻数据
  • (一)C语言之入门:使用Visual Studio Community 2022运行hello world
  • (已更新)关于Visual Studio 2019安装时VS installer无法下载文件,进度条为0,显示网络有问题的解决办法
  • (转)Sublime Text3配置Lua运行环境
  • (转载)OpenStack Hacker养成指南
  • .htaccess 强制https 单独排除某个目录
  • .NET : 在VS2008中计算代码度量值
  • .net core webapi Startup 注入ConfigurePrimaryHttpMessageHandler
  • .net core webapi 部署iis_一键部署VS插件:让.NET开发者更幸福
  • .NET MVC第三章、三种传值方式
  • .NET 设计模式—适配器模式(Adapter Pattern)
  • .Net下使用 Geb.Video.FFMPEG 操作视频文件