Re: 任务本地运行正常,提交到集群报错 - 图片挂掉,文字贴一下报错信息,非常抱歉打扰
ping 127.0.0.1:33271 可以ping通吗 Best regards, Weijie yidan zhao 于2023年1月12日周四 17:48写道: > 看报错 Could not connect to BlobServer at address > localhost/127.0.0.1:33271,你本地的配置是不是不对。提交到什么模式部署的集群,配置是否配对了。 > > WD.Z 于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) >
Re: 任务本地运行正常,提交到集群报错 - 图片挂掉,文字贴一下报错信息,非常抱歉打扰
看报错 Could not connect to BlobServer at address localhost/127.0.0.1:33271,你本地的配置是不是不对。提交到什么模式部署的集群,配置是否配对了。 WD.Z 于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)
任务本地运行正常,提交到集群报错 - 图片挂掉,文字贴一下报错信息,非常抱歉打扰
任务在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)