flink 1.4无法检索blobserver地址

aiazj4mn  于 2021-06-25  发布在  Flink
关注(0)|答案(1)|浏览(282)

当使用flink1.4、jdk1.8.0151、kafka和table query时,出现了以下异常。从日志中看,blobserver似乎启动然后关闭。我有一种感觉,这与缺少依赖性有关?
我的身材。grad尔:

dependencies {
compile group: 'log4j', name: 'log4j', version: '1.2.17'
compile 'org.apache.flink:flink-java:1.4.0'
compile 'org.apache.flink:flink-streaming-java_2.11:1.4.0'
compile 'org.apache.flink:flink-clients_2.11:1.4.0'
compile 'org.apache.flink:flink-table_2.11:1.4.0'
compile 'org.apache.flink:flink-scala_2.11:1.4.0'
compile 'org.apache.flink:flink-streaming-scala_2.11:1.4.0'
compile 'org.apache.flink:flink-connector-kafka-0.8_2.11:1.4.0'
compile 'org.apache.flink:flink-queryable-state-runtime_2.11:1.4.0'
compile 'org.apache.flink:flink-queryable-state-client-java__2.11:1.4.0'
testCompile 'junit:junit:+'
}

在intellij中运行时出现的异常:

2018-01-11 09:23:36 AM INFO  JobClient:326 - Job execution failed
2018-01-11 09:23:36 AM INFO  FlinkMiniCluster:433 - Stopping FlinkMiniCluster.
2018-01-11 09:23:36 AM INFO  JobSubmissionClientActor:337 - Terminate JobClientActor.
2018-01-11 09:23:36 AM INFO  JobSubmissionClientActor:315 - Disconnect from JobManager Actor[akka://flink/user/jobmanager_1#587536570].
2018-01-11 09:23:36 AM INFO  TaskManager:128 - Stopping TaskManager akka://flink/user/taskmanager_1#259478943.
2018-01-11 09:23:36 AM INFO  TaskManager:128 - Disassociating from JobManager
2018-01-11 09:23:36 AM INFO  PermanentBlobCache:225 - Shutting down BLOB cache
2018-01-11 09:23:36 AM INFO  TransientBlobCache:225 - Shutting down BLOB cache
2018-01-11 09:23:36 AM INFO  IOManager:110 - I/O manager removed spill file directory /tmp/flink-io-01a605f7-0df5-4494-8acf-cbea6dfa90ee
2018-01-11 09:23:36 AM INFO  NetworkEnvironment:341 - Shutting down the network environment and its components.
2018-01-11 09:23:36 AM INFO  TaskManager:128 - Task manager akka://flink/user/taskmanager_1 is completely shut down.
2018-01-11 09:23:36 AM INFO  JobManager:128 - Stopping JobManager akka://flink/user/jobmanager_1.
2018-01-11 09:23:36 AM INFO  BlobServer:364 - Stopped BLOB server at 0.0.0.0:46717
Exception in thread "main" org.apache.flink.runtime.client.JobSubmissionException: Could not retrieve BlobServer address.
at org.apache.flink.runtime.client.JobSubmissionClientActor$1.call(JobSubmissionClientActor.java:166)
at akka.dispatch.Futures$$anonfun$future$1.apply(Future.scala:97)
vptzau2j

vptzau2j1#

固定在https://issues.apache.org/jira/browse/flink-8485 因为我只有一个核心处理器。

相关问题