Flink 1.4无法检索BlobServer地址

Question

当使用Flink1.4，JDK 1.8.0_151，以及Kafka和表查询时，我得到了以下异常。从日志中看，BlobServer似乎是先启动后关闭。我有一种感觉，它与缺失的依赖项有关？

我的build.gradle：

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)

Answer 1

修复了https://issues.apache.org/jira/browse/FLINK-8485中的问题，因为我只有一个核心处理器。