You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 孙冬燕 <su...@alibaba-inc.com.INVALID> on 2023/02/03 02:26:29 UTC
flink提交jar包时报连接不上BlobServer

2023-02-02 19:21:21,288 WARN org.apache.flink.client.deployment.application.DetachedApplicationRunner [] - Could not execute application: 
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Failed to execute job 'Flink Streaming Job'.
 at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:98) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:84) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.DetachedApplicationRunner.run(DetachedApplicationRunner.java:70) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$0(JarRunHandler.java:107) ~[flink-dist-1.16.0.jar:1.16.0]
 at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) [?:1.8.0_66]
 at java.lang.Thread.run(Thread.java:756) [?:1.8.0_66]
Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'Flink Streaming Job'.
 at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2203) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:206) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.program.StreamContextEnvironment.execute(StreamContextEnvironment.java:144) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2049) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2027) ~[flink-dist-1.16.0.jar:1.16.0]
 at me.ele.arch.emonitor.blink.DataStreamApplication.main(DataStreamApplication.java:48) ~[?:?]
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_66]
 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_66]
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_66]
 at java.lang.reflect.Method.invoke(Method.java:497) ~[?:1.8.0_66]
 at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) ~[flink-dist-1.16.0.jar:1.16.0]
 ... 7 more
Caused by: org.apache.flink.util.FlinkException: Could not upload job files.
 at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:86) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.runtime.client.ClientUtils.extractAndUploadJobGraphFiles(ClientUtils.java:62) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.lambda$submitJob$6(EmbeddedExecutor.java:177) ~[flink-dist-1.16.0.jar:1.16.0]
 at java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:981) ~[?:1.8.0_66]
 at java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2124) ~[?:1.8.0_66]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.submitJob(EmbeddedExecutor.java:174) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.submitAndGetJobClientFuture(EmbeddedExecutor.java:134) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.execute(EmbeddedExecutor.java:104) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2188) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:206) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.program.StreamContextEnvironment.execute(StreamContextEnvironment.java:144) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2049) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2027) ~[flink-dist-1.16.0.jar:1.16.0]
 at me.ele.arch.emonitor.blink.DataStreamApplication.main(DataStreamApplication.java:48) ~[?:?]
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_66]
 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_66]
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_66]
 at java.lang.reflect.Method.invoke(Method.java:497) ~[?:1.8.0_66]
 at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) ~[flink-dist-1.16.0.jar:1.16.0]
 ... 7 more
Caused by: java.io.IOException: Could not connect to BlobServer at address localhost/127.0.0.1:21198
 at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:103) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.lambda$null$5(EmbeddedExecutor.java:179) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:82) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.runtime.client.ClientUtils.extractAndUploadJobGraphFiles(ClientUtils.java:62) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.lambda$submitJob$6(EmbeddedExecutor.java:177) ~[flink-dist-1.16.0.jar:1.16.0]
 at java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:981) ~[?:1.8.0_66]
 at java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2124) ~[?:1.8.0_66]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.submitJob(EmbeddedExecutor.java:174) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.submitAndGetJobClientFuture(EmbeddedExecutor.java:134) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.execute(EmbeddedExecutor.java:104) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2188) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:206) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.program.StreamContextEnvironment.execute(StreamContextEnvironment.java:144) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2049) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2027) ~[flink-dist-1.16.0.jar:1.16.0]
 at me.ele.arch.emonitor.blink.DataStreamApplication.main(DataStreamApplication.java:48) ~[?:?]
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_66]
 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_66]
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_66]
 at java.lang.reflect.Method.invoke(Method.java:497) ~[?:1.8.0_66]
 at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) ~[flink-dist-1.16.0.jar:1.16.0]
 ... 7 more
Caused by: java.net.ConnectException: Connection refused
 at java.net.PlainSocketImpl.socketConnect(Native Method) ~[?:1.8.0_66]
 at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) ~[?:1.8.0_66]
 at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[?:1.8.0_66]
 at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) ~[?:1.8.0_66]
 at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[?:1.8.0_66]
 at java.net.Socket.connect(Socket.java:589) ~[?:1.8.0_66]
 at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:97) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.lambda$null$5(EmbeddedExecutor.java:179) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:82) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.runtime.client.ClientUtils.extractAndUploadJobGraphFiles(ClientUtils.java:62) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.lambda$submitJob$6(EmbeddedExecutor.java:177) ~[flink-dist-1.16.0.jar:1.16.0]
 at java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:981) ~[?:1.8.0_66]
 at java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2124) ~[?:1.8.0_66]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.submitJob(EmbeddedExecutor.java:174) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.submitAndGetJobClientFuture(EmbeddedExecutor.java:134) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.execute(EmbeddedExecutor.java:104) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2188) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:206) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.client.program.StreamContextEnvironment.execute(StreamContextEnvironment.java:144) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2049) ~[flink-dist-1.16.0.jar:1.16.0]
 at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2027) ~[flink-dist-1.16.0.jar:1.16.0]
 at me.ele.arch.emonitor.blink.DataStreamApplication.main(DataStreamApplication.java:48) ~[?:?]
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_66]
 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_66]
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_66]
 at java.lang.reflect.Method.invoke(Method.java:497) ~[?:1.8.0_66]
 at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) ~[flink-dist-1.16.0.jar:1.16.0]