enclosed the logs.. maybe you can make some sense out if them. On 03/31/2016 02:52 PM, Till Rohrmann wrote: > I would assume that something went wrong on the JobManager side. Could you > check the logs if they contain something suspicious? Additionally you could > turn on lifecycle event logging​ for Akka. > > Cheers, > Till > ​ >
2016-03-31 16:17:22,950 INFO org.apache.flink.client.CliFrontend - --------------------------------------------------------------------------------
2016-03-31 16:17:22,951 INFO org.apache.flink.client.CliFrontend - Starting Command Line Client (Version: 1.1-SNAPSHOT, Rev:bdf55b9, Date:30.03.2016 @ 19:19:23 CEST)
2016-03-31 16:17:22,951 INFO org.apache.flink.client.CliFrontend - Current user: mjsax
2016-03-31 16:17:22,951 INFO org.apache.flink.client.CliFrontend - JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.7/24.95-b01
2016-03-31 16:17:22,951 INFO org.apache.flink.client.CliFrontend - Maximum heap size: 1769 MiBytes
2016-03-31 16:17:22,951 INFO org.apache.flink.client.CliFrontend - JAVA_HOME: /usr/lib/jvm/java-7-openjdk-amd64
2016-03-31 16:17:22,953 INFO org.apache.flink.client.CliFrontend - Hadoop version: 2.3.0
2016-03-31 16:17:22,953 INFO org.apache.flink.client.CliFrontend - JVM Options:
2016-03-31 16:17:22,953 INFO org.apache.flink.client.CliFrontend - -Dlog.file=/home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/log/flink-mjsax-client-T420s-dbis-mjsax.log
2016-03-31 16:17:22,953 INFO org.apache.flink.client.CliFrontend - -Dlog4j.configuration=file:/home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/conf/log4j-cli.properties
2016-03-31 16:17:22,953 INFO org.apache.flink.client.CliFrontend - -Dlogback.configurationFile=file:/home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/conf/logback.xml
2016-03-31 16:17:22,953 INFO org.apache.flink.client.CliFrontend - Program Arguments:
2016-03-31 16:17:22,953 INFO org.apache.flink.client.CliFrontend - run
2016-03-31 16:17:22,953 INFO org.apache.flink.client.CliFrontend - /home/mjsax/workspace_flink/flink/flink-contrib/flink-storm-examples/target/WordCount-StormTopology.jar
2016-03-31 16:17:22,953 INFO org.apache.flink.client.CliFrontend - Classpath: /home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/lib/flink-dist_2.10-1.1-SNAPSHOT.jar:/home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/lib/flink-python_2.10-1.1-SNAPSHOT.jar:/home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/lib/log4j-1.2.17.jar:/home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/lib/slf4j-log4j12-1.7.7.jar:::
2016-03-31 16:17:22,953 INFO org.apache.flink.client.CliFrontend - --------------------------------------------------------------------------------
2016-03-31 16:17:22,953 INFO org.apache.flink.client.CliFrontend - Using configuration directory /home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/conf
2016-03-31 16:17:22,954 INFO org.apache.flink.client.CliFrontend - Trying to load configuration file
2016-03-31 16:17:23,220 INFO org.apache.flink.client.CliFrontend - Running 'run' command.
2016-03-31 16:17:23,230 INFO org.apache.flink.client.CliFrontend - Building program from JAR file
2016-03-31 16:17:23,261 INFO org.apache.flink.client.program.Client - Starting client actor system
2016-03-31 16:17:23,263 INFO org.apache.flink.runtime.client.JobClient - Starting JobClient actor system
2016-03-31 16:17:23,655 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
2016-03-31 16:17:23,691 INFO Remoting - Starting remoting
2016-03-31 16:17:23,808 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://flink@127.0.0.1:39643]
2016-03-31 16:17:23,813 INFO org.apache.flink.runtime.client.JobClient - Started JobClient actor system at 127.0.0.1:39643
2016-03-31 16:17:23,813 INFO org.apache.flink.client.CliFrontend - Starting execution of program
2016-03-31 16:17:23,813 INFO org.apache.flink.client.program.Client - Starting program in interactive mode
2016-03-31 16:17:24,016 INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer$DefaultComparable is not public, cannot treat it as a POJO type. Will be handled as GenericType
2016-03-31 16:17:24,017 INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer$DefaultComparable is not public, cannot treat it as a POJO type. Will be handled as GenericType
2016-03-31 16:17:24,038 INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer$DefaultComparable is not public, cannot treat it as a POJO type. Will be handled as GenericType
2016-03-31 16:17:24,038 INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer$DefaultComparable is not public, cannot treat it as a POJO type. Will be handled as GenericType
2016-03-31 16:17:24,038 INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer$DefaultComparable is not public, cannot treat it as a POJO type. Will be handled as GenericType
2016-03-31 16:17:24,057 INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer$DefaultComparable is not public, cannot treat it as a POJO type. Will be handled as GenericType
2016-03-31 16:17:24,057 INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer$DefaultComparable is not public, cannot treat it as a POJO type. Will be handled as GenericType
2016-03-31 16:17:24,057 INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer$DefaultComparable is not public, cannot treat it as a POJO type. Will be handled as GenericType
2016-03-31 16:17:24,129 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
2016-03-31 16:17:24,134 INFO Remoting - Starting remoting
2016-03-31 16:17:24,144 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://flink@127.0.0.1:33882]
2016-03-31 16:17:24,392 INFO org.apache.flink.storm.api.FlinkSubmitter - Submitting topology Storm WordCount in distributed mode with conf {"nimbus.host":"localhost","nimbus.thrift.port":6123}
2016-03-31 16:17:24,415 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
2016-03-31 16:17:24,421 INFO Remoting - Starting remoting
2016-03-31 16:17:24,431 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://flink@127.0.0.1:33653]
2016-03-31 16:17:24,513 INFO org.apache.flink.client.program.Client - Starting client actor system
2016-03-31 16:17:24,513 INFO org.apache.flink.runtime.client.JobClient - Starting JobClient actor system
2016-03-31 16:17:24,532 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
2016-03-31 16:17:24,537 INFO Remoting - Starting remoting
2016-03-31 16:17:24,546 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://flink@127.0.0.1:55846]
2016-03-31 16:17:24,547 INFO org.apache.flink.runtime.client.JobClient - Started JobClient actor system at 127.0.0.1:55846
2016-03-31 16:17:24,549 INFO org.apache.flink.client.program.Client - Looking up JobManager
2016-03-31 16:17:24,576 INFO org.apache.flink.client.program.Client - Checking and uploading JAR files
2016-03-31 16:17:24,736 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@127.0.0.1:6123] has failed, address is now gated for [5000] ms. Reason is: [Disassociated].
2016-03-31 16:18:24,659 ERROR org.apache.flink.client.CliFrontend - Error while running the command.
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:520)
at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:403)
at org.apache.flink.client.program.Client.runBlocking(Client.java:248)
at org.apache.flink.client.CliFrontend.executeProgramBlocking(CliFrontend.java:860)
at org.apache.flink.client.CliFrontend.run(CliFrontend.java:327)
at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1184)
at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1234)
Caused by: java.lang.RuntimeException: Cannot execute job due to ProgramInvocationException
at org.apache.flink.storm.api.FlinkClient.submitTopologyWithOpts(FlinkClient.java:222)
at org.apache.flink.storm.api.FlinkSubmitter.submitTopology(FlinkSubmitter.java:125)
at org.apache.flink.storm.wordcount.WordCountRemoteBySubmitter.main(WordCountRemoteBySubmitter.java:75)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:505)
... 6 more
Caused by: org.apache.flink.client.program.ProgramInvocationException: The program execution failed: JobManager did not respond within 60000 milliseconds
at org.apache.flink.client.program.Client.runDetached(Client.java:406)
at org.apache.flink.storm.api.FlinkClient.submitTopologyWithOpts(FlinkClient.java:220)
... 13 more
Caused by: org.apache.flink.runtime.client.JobTimeoutException: JobManager did not respond within 60000 milliseconds
at org.apache.flink.runtime.client.JobClient.submitJobDetached(JobClient.java:221)
at org.apache.flink.client.program.Client.runDetached(Client.java:403)
... 14 more
Caused by: java.util.concurrent.TimeoutException: Futures timed out after [60000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at org.apache.flink.runtime.client.JobClient.submitJobDetached(JobClient.java:218)
... 15 more
2016-03-31 16:18:24,676 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
2016-03-31 16:18:24,679 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
2016-03-31 16:18:24,701 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
2016-03-31 16:17:13,427 WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 2016-03-31 16:17:13,596 INFO org.apache.flink.runtime.jobmanager.JobManager - -------------------------------------------------------------------------------- 2016-03-31 16:17:13,596 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager (Version: 1.1-SNAPSHOT, Rev:bdf55b9, Date:30.03.2016 @ 19:19:23 CEST) 2016-03-31 16:17:13,596 INFO org.apache.flink.runtime.jobmanager.JobManager - Current user: mjsax 2016-03-31 16:17:13,596 INFO org.apache.flink.runtime.jobmanager.JobManager - JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.7/24.95-b01 2016-03-31 16:17:13,596 INFO org.apache.flink.runtime.jobmanager.JobManager - Maximum heap size: 736 MiBytes 2016-03-31 16:17:13,596 INFO org.apache.flink.runtime.jobmanager.JobManager - JAVA_HOME: /usr/lib/jvm/java-7-openjdk-amd64 2016-03-31 16:17:13,599 INFO org.apache.flink.runtime.jobmanager.JobManager - Hadoop version: 2.3.0 2016-03-31 16:17:13,599 INFO org.apache.flink.runtime.jobmanager.JobManager - JVM Options: 2016-03-31 16:17:13,599 INFO org.apache.flink.runtime.jobmanager.JobManager - -Xms768m 2016-03-31 16:17:13,599 INFO org.apache.flink.runtime.jobmanager.JobManager - -Xmx768m 2016-03-31 16:17:13,599 INFO org.apache.flink.runtime.jobmanager.JobManager - -XX:MaxPermSize=256m 2016-03-31 16:17:13,599 INFO org.apache.flink.runtime.jobmanager.JobManager - -Dlog.file=/home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/log/flink-mjsax-jobmanager-0-T420s-dbis-mjsax.log 2016-03-31 16:17:13,599 INFO org.apache.flink.runtime.jobmanager.JobManager - -Dlog4j.configuration=file:/home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/conf/log4j.properties 2016-03-31 16:17:13,600 INFO org.apache.flink.runtime.jobmanager.JobManager - -Dlogback.configurationFile=file:/home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/conf/logback.xml 2016-03-31 16:17:13,600 INFO org.apache.flink.runtime.jobmanager.JobManager - Program Arguments: 2016-03-31 16:17:13,600 INFO org.apache.flink.runtime.jobmanager.JobManager - --configDir 2016-03-31 16:17:13,600 INFO org.apache.flink.runtime.jobmanager.JobManager - /home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/conf 2016-03-31 16:17:13,600 INFO org.apache.flink.runtime.jobmanager.JobManager - --executionMode 2016-03-31 16:17:13,600 INFO org.apache.flink.runtime.jobmanager.JobManager - local 2016-03-31 16:17:13,600 INFO org.apache.flink.runtime.jobmanager.JobManager - Classpath: /home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/lib/flink-dist_2.10-1.1-SNAPSHOT.jar:/home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/lib/flink-python_2.10-1.1-SNAPSHOT.jar:/home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/lib/log4j-1.2.17.jar:/home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/lib/slf4j-log4j12-1.7.7.jar::: 2016-03-31 16:17:13,600 INFO org.apache.flink.runtime.jobmanager.JobManager - -------------------------------------------------------------------------------- 2016-03-31 16:17:13,601 INFO org.apache.flink.runtime.jobmanager.JobManager - Registered UNIX signal handlers for [TERM, HUP, INT] 2016-03-31 16:17:13,755 INFO org.apache.flink.runtime.jobmanager.JobManager - Loading configuration from /home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/conf 2016-03-31 16:17:13,769 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager without high-availability 2016-03-31 16:17:13,776 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager on 127.0.0.1:6123 with execution mode LOCAL 2016-03-31 16:17:13,859 INFO org.apache.flink.runtime.jobmanager.JobManager - Security is not enabled. Starting non-authenticated JobManager. 2016-03-31 16:17:13,869 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager 2016-03-31 16:17:13,870 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager actor system at 127.0.0.1:6123 2016-03-31 16:17:14,302 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started 2016-03-31 16:17:14,344 INFO Remoting - Starting remoting 2016-03-31 16:17:14,470 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://flink@127.0.0.1:6123] 2016-03-31 16:17:14,476 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager web frontend 2016-03-31 16:17:14,489 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined location of JobManager log file: /home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/log/flink-mjsax-jobmanager-0-T420s-dbis-mjsax.log 2016-03-31 16:17:14,489 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined location of JobManager stdout file: /home/mjsax/workspace_flink/flink/flink-dist/target/flink-1.1-SNAPSHOT-bin/flink-1.1-SNAPSHOT/log/flink-mjsax-jobmanager-0-T420s-dbis-mjsax.out 2016-03-31 16:17:14,497 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Using directory /tmp/flink-web-7081f6d9-e0cc-401d-8a1e-185745451d14 for the web interface files 2016-03-31 16:17:14,498 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Using directory /tmp/flink-web-upload-f45e4bb5-9a7b-4cc4-8ec1-9d22c9d3e86b for web frontend JAR file uploads 2016-03-31 16:17:14,712 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Web frontend listening at 0:0:0:0:0:0:0:0:8081 2016-03-31 16:17:14,713 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager actor 2016-03-31 16:17:14,716 INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory /tmp/blobStore-32f577ff-092a-4b1b-85bd-5e2ebba46635 2016-03-31 16:17:14,717 INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:39987 - max concurrent requests: 50 - max backlog: 1000 2016-03-31 16:17:14,724 INFO org.apache.flink.runtime.checkpoint.SavepointStoreFactory - Using job manager savepoint state backend. 2016-03-31 16:17:14,728 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting embedded TaskManager for JobManager's LOCAL execution mode 2016-03-31 16:17:14,732 INFO org.apache.flink.runtime.jobmanager.MemoryArchivist - Started memory archivist akka://flink/user/archive 2016-03-31 16:17:14,733 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager at akka.tcp://flink@127.0.0.1:6123/user/jobmanager. 2016-03-31 16:17:14,738 INFO org.apache.flink.runtime.jobmanager.JobManager - JobManager akka.tcp://flink@127.0.0.1:6123/user/jobmanager was granted leadership with leader session ID None. 2016-03-31 16:17:14,741 INFO org.apache.flink.runtime.taskmanager.TaskManager - Messages between TaskManager and JobManager have a max timeout of 10000 milliseconds 2016-03-31 16:17:14,744 INFO org.apache.flink.runtime.taskmanager.TaskManager - Temporary file directory '/tmp': total 7 GB, usable 6 GB (85.71% usable) 2016-03-31 16:17:14,835 INFO org.apache.flink.runtime.io.network.buffer.NetworkBufferPool - Allocated 64 MB for network buffer pool (number of memory segments: 2048, bytes per segment: 32768). 2016-03-31 16:17:14,986 INFO org.apache.flink.runtime.taskmanager.TaskManager - Limiting managed memory to 0.7 of the currently free heap space (457 MB), memory will be allocated lazily. 2016-03-31 16:17:14,990 INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager uses directory /tmp/flink-io-90386f81-8850-4cf3-b800-92fd148f289f for spill files. 2016-03-31 16:17:14,994 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Starting with JobManager akka.tcp://flink@127.0.0.1:6123/user/jobmanager on port 8081 2016-03-31 16:17:14,994 INFO org.apache.flink.runtime.webmonitor.JobManagerRetriever - New leader reachable under akka.tcp://flink@127.0.0.1:6123/user/jobmanager:null. 2016-03-31 16:17:14,997 INFO org.apache.flink.runtime.filecache.FileCache - User file cache uses directory /tmp/flink-dist-cache-90494293-6309-49da-8e0a-397bf7ae7286 2016-03-31 16:17:15,027 INFO org.apache.flink.runtime.clusterframework.standalone.StandaloneResourceManager - Trying to associate with JobManager leader akka.tcp://flink@127.0.0.1:6123/user/jobmanager 2016-03-31 16:17:15,034 INFO org.apache.flink.runtime.clusterframework.standalone.StandaloneResourceManager - Resource Manager associating with leading JobManager Actor[akka://flink/user/jobmanager#-619565000] - leader session null 2016-03-31 16:17:15,161 INFO org.apache.flink.runtime.taskmanager.TaskManager - Starting TaskManager actor at akka://flink/user/taskmanager#829877497. 2016-03-31 16:17:15,161 INFO org.apache.flink.runtime.taskmanager.TaskManager - TaskManager data connection information: localhost (dataPort=53300) 2016-03-31 16:17:15,162 INFO org.apache.flink.runtime.taskmanager.TaskManager - TaskManager has 4 task slot(s). 2016-03-31 16:17:15,163 INFO org.apache.flink.runtime.taskmanager.TaskManager - Memory usage stats: [HEAP: 103/736/736 MB, NON HEAP: 30/54/304 MB (used/committed/max)] 2016-03-31 16:17:15,166 INFO org.apache.flink.runtime.taskmanager.TaskManager - Trying to register at JobManager akka.tcp://flink@127.0.0.1:6123/user/jobmanager (attempt 1, timeout: 500 milliseconds) 2016-03-31 16:17:15,170 INFO org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager at localhost (akka://flink/user/taskmanager) as 94ddfbbee7bc14c9c01408bf242b4337. Current number of registered hosts is 1. Current number of alive task slots is 4. 2016-03-31 16:17:15,177 INFO org.apache.flink.runtime.taskmanager.TaskManager - Successful registration at JobManager (akka://flink/user/jobmanager), starting network stack and library cache. 2016-03-31 16:17:15,188 INFO org.apache.flink.runtime.taskmanager.TaskManager - Determined BLOB server address to be localhost/127.0.0.1:39987. Starting BLOB cache. 2016-03-31 16:17:15,189 INFO org.apache.flink.runtime.blob.BlobCache - Created BLOB cache storage directory /tmp/blobStore-e2ef51d8-39ea-4b34-b38f-56df8ea1bf1b 2016-03-31 16:17:24,713 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@127.0.0.1:55846] has failed, address is now gated for [5000] ms. Reason is: [org.apache.flink.storm.util.StormConfig]. 2016-03-31 16:18:25,065 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@127.0.0.1:33882] has failed, address is now gated for [5000] ms. Reason is: [Disassociated]. 2016-03-31 16:18:25,066 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@127.0.0.1:33653] has failed, address is now gated for [5000] ms. Reason is: [Disassociated].
signature.asc
Description: OpenPGP digital signature
