看报错 Could not connect to BlobServer at address localhost/127.0.0.1:33271,你本地的配置是不是不对。提交到什么模式部署的集群,配置是否配对了。
WD.Z <zwdrsd...@163.com> 于2023年1月10日周二 10:56写道: > > 任务在webui点击submit时报错,看起来是从JM提交到TM时报错,服务器防火墙已关闭,资源足够,还没有安装hadoop,但以standalone模式启动,看了下文档是不需要hadoop? > 报错中的Caused by列表如下: > > > 2023-01-10 09:46:14,627 INFO > org.apache.flink.client.deployment.application.executors.EmbeddedExecutor [] > - Job e343bc906ea6889d34d9472d40d4f8ff is submitted. > 2023-01-10 09:46:14,627 INFO > org.apache.flink.client.deployment.application.executors.EmbeddedExecutor [] > - Submitting Job with JobId=e343bc906ea6889d34d9472d40d4f8ff. > 2023-01-10 09:46:14,629 WARN > org.apache.flink.client.deployment.application.DetachedApplicationRunner [] - > Could not execute application: > org.apache.flink.client.program.ProgramInvocationException: The main method > caused an error: org.apache.flink.util.FlinkException: Failed to execute job > 'Flink Streaming Job'. > > > Caused by: java.lang.RuntimeException: org.apache.flink.util.FlinkException: > Failed to execute job 'Flink Streaming Job'. > > > Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'Flink > Streaming Job'. > > > Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'Flink > Streaming Job'. > > > Caused by: org.apache.flink.util.FlinkException: Could not upload job files. > > > Caused by: java.io.IOException: Could not connect to BlobServer at address > localhost/127.0.0.1:33271 > > > Caused by: java.net.ConnectException: 拒绝连接 (Connection refused)