apache-flink - Flink作业错误java.util.concurrent.ExecutionException:org.apache.flink.runtime.client.JobSubmissionException:无法提交JobGraph
问题描述
Flink 作业提交
# ./bin/flink run -m 10.0.2.4:6123 /storage/flink-1.10.0/examples/streaming/WordCount.jar --input /storage/flink-1.10.0/test.txt --output /storage/flink-1.10.0/test01.txt
------------------------------------------------------------
The program finished with the following exception:
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
$ ./bin/flink run -m 10.0.2.4:6123 /streaming/mvn-flinkstreaming-scala/mvn-flinkstreaming-scala-1.0.jar
Stream processing!!!!!!!!!!!!!!!!!
org.apache.flink.streaming.api.datastream.DataStreamSink@40ef3420
------------------------------------------------------------
The program finished with the following exception:
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
如何解决此问题,我尝试了示例作业和示例流作业,两个 jar 文件都出现了相同的错误。
解决方案
推荐阅读
- next.js - 在下一个 js 中从父级传递到组件时,道具未定义
- node.js - Firebase-admin nodejs SDK 无法连接
- c# - 使用 C# HttpClient 时收到 HTTP 500 响应
- excel - 如何在excel中为矩阵形式计算不同的值
- anglesharp - 我如何解析 document.write/response.write 以对 AngleSharp 使用单引号而不是双引号?
- sql-server - Apache 授权使用 SQL Server 数据库中的要求 dbd-group
- c# - 单击 NavigationViewPaneDisplayMode 时启用一键而不是双击
- kotlin - 如何在 Kotlin 的类中解决 getter
- python-packaging - 诗歌:如何发布针对多个 Python 版本的项目包?
- docker - Docker 容器无法连接到我知道正在运行的另一个容器