当使用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)
1条答案
按热度按时间vptzau2j1#
固定在https://issues.apache.org/jira/browse/flink-8485 因为我只有一个核心处理器。