Are you facing these issues with the batch or streaming programs? – Ufuk
On Wed, Mar 16, 2016 at 4:30 PM, Till Rohrmann <trohrm...@apache.org> wrote: > If the problem is that your JVMs stall too long, then you can also increase > the akka.ask.timeout configuration value in flink-config.yaml. That will > also increase the timeout for the failure detector. Or you set the values > for Akka’s deathwatch yourself to some greater values. See the configuration > docs [1] for a list of available options. > > [1] > https://ci.apache.org/projects/flink/flink-docs-master/setup/config.html#distributed-coordination-via-akka > > Cheers, > Till > > > On Wed, Mar 16, 2016 at 4:25 PM, Ravinder Kaur <neetu0...@gmail.com> wrote: >> >> Hello All, >> >> I have been facing the Loss of TaskManager issues again. But the >> JobManager and TaskManager logs showed that either of them went unreachable >> while the job ran with the following error. >> >> akka.remote.RemoteWatcher: Detected unreachable >> >> Much speculation brought me to >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/JobManager-is-no-longer-reachable-td1821.html >> >> Following the suggestions by Stephan, only after using the G1 garbage >> collector the Job stopped failing. But after using G1 the runtime has >> increased by 50%. How can this be explained? >> >> Kind Regards, >> Ravinder Kaur >> >> >> >> On Tue, Mar 15, 2016 at 11:20 PM, Ravinder Kaur <neetu0...@gmail.com> >> wrote: >>> >>> Hello All, >>> >>> I figured out that it was not a problem with GC stalls but improper >>> memory management. I increased the taskmanager.memory.fraction from 0.5 -> >>> 0.6. >>> >>> This solved the errors and I could run the jobs successfully. >>> >>> Kind Regards, >>> Ravinder. >>> >>> On Tue, Mar 15, 2016 at 7:21 PM, Ravinder Kaur <neetu0...@gmail.com> >>> wrote: >>>> >>>> Hi Till, >>>> >>>> After running a few jobs, the Taskmanagers are lost again. >>>> >>>> 03/15/2016 18:41:45 Source: Read Text File Source -> Flat Map(8/25) >>>> switched to FINISHED >>>> 03/15/2016 18:43:27 Keyed Aggregation -> Sink: Unnamed(3/25) >>>> switched to FAILED >>>> java.lang.Exception: The slot in which the task was executed has been >>>> released. Probably loss of TaskManager 50d28775a642f8f19834beb607f01035 @ >>>> vm-10-155-208-138 - 4 slots - URL: >>>> akka.tcp://flink@10.155.208.138:32846/user/taskmanager >>>> at >>>> org.apache.flink.runtime.instance.SimpleSlot.releaseSlot(SimpleSlot.java:153) >>>> at >>>> org.apache.flink.runtime.instance.SlotSharingGroupAssignment.releaseSharedSlot(SlotSharingGroupAssignment.java:547) >>>> at >>>> org.apache.flink.runtime.instance.SharedSlot.releaseSlot(SharedSlot.java:119) >>>> at >>>> org.apache.flink.runtime.instance.Instance.markDead(Instance.java:156) >>>> at >>>> org.apache.flink.runtime.instance.InstanceManager.unregisterTaskManager(InstanceManager.java:215) >>>> at >>>> org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1.applyOrElse(JobManager.scala:696) >>>> at >>>> scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) >>>> at >>>> org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:44) >>>> at >>>> scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) >>>> at >>>> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33) >>>> at >>>> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28) >>>> at >>>> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) >>>> at >>>> org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28) >>>> at akka.actor.Actor$class.aroundReceive(Actor.scala:465) >>>> at >>>> org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:100) >>>> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) >>>> at >>>> akka.actor.dungeon.DeathWatch$class.receivedTerminated(DeathWatch.scala:46) >>>> at akka.actor.ActorCell.receivedTerminated(ActorCell.scala:369) >>>> at akka.actor.ActorCell.autoReceiveMessage(ActorCell.scala:501) >>>> at akka.actor.ActorCell.invoke(ActorCell.scala:486) >>>> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) >>>> at akka.dispatch.Mailbox.run(Mailbox.scala:221) >>>> at akka.dispatch.Mailbox.exec(Mailbox.scala:231) >>>> at >>>> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) >>>> at >>>> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) >>>> at >>>> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) >>>> at >>>> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) >>>> >>>> 03/15/2016 18:43:27 Job execution switched to status FAILING. >>>> 03/15/2016 18:43:27 Source: Read Text File Source -> Flat Map(2/25) >>>> switched to CANCELING >>>> 03/15/2016 18:43:27 Source: Read Text File Source -> Flat Map(3/25) >>>> switched to CANCELING >>>> >>>> Inspecting the logs showed the following >>>> >>>> JobManager >>>> >>>> 18:40:35,810 INFO org.apache.flink.streaming.runtime.tasks.StreamTask >>>> - State backend is set to heap memory (checkpoint to jobmanager) >>>> 18:40:35,813 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Keyed Aggregation -> Sink: Unnamed (18/25) switched to RUNNING >>>> 18:41:14,488 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Source: Read Text File Source -> Flat Map (5/25) switched to FINISHED >>>> 18:41:14,488 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Freeing task resources for Source: Read Text File Source -> Flat Map >>>> (5/25) >>>> 18:41:14,490 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>> - Unregistering task and sending final execution state FINISHED to >>>> JobManager for task Source: Read Text File Source -> Flat Map >>>> (f161c748e7b489872cabe66c605a1191) >>>> 18:41:14,804 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Source: Read Text File Source -> Flat Map (12/25) switched to FINISHED >>>> 18:41:14,804 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Freeing task resources for Source: Read Text File Source -> Flat Map >>>> (12/25) >>>> 18:41:14,805 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>> - Unregistering task and sending final execution state FINISHED to >>>> JobManager for task Source: Read Text File Source -> Flat Map >>>> (8851f0ae8b3863ba74d7a075d86269d8) >>>> 18:41:14,984 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Source: Read Text File Source -> Flat Map (19/25) switched to FINISHED >>>> 18:41:14,984 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Freeing task resources for Source: Read Text File Source -> Flat Map >>>> (19/25) >>>> 18:41:14,984 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>> - Unregistering task and sending final execution state FINISHED to >>>> JobManager for task Source: Read Text File Source -> Flat Map >>>> (682f9c4f7a90625517116e80e94bacb2) >>>> 18:43:27,314 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>> - Discarding the results produced by task execution >>>> f161c748e7b489872cabe66c605a1191 >>>> 18:43:27,334 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Keyed Aggregation -> Sink: Unnamed (16/25) switched to FAILED with >>>> exception. >>>> >>>> org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException: >>>> Error at remote task manager >>>> 'vm-10-155-208-138.cloud.mwn.de/10.155.208.138:43337'. >>>> at >>>> org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler.decodeMsg(PartitionRequestClientHandler.java:241) >>>> at >>>> org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler.channelRead(PartitionRequestClientHandler.java:164) >>>> at >>>> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308) >>>> at >>>> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294) >>>> at >>>> io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) >>>> at >>>> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308) >>>> at >>>> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294) >>>> at >>>> io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:244) >>>> at >>>> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308) >>>> at >>>> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294) >>>> at >>>> io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846) >>>> at >>>> io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131) >>>> at >>>> io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511) >>>> at >>>> io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) >>>> at >>>> io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) >>>> at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) >>>> at >>>> io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112) >>>> at java.lang.Thread.run(Thread.java:745) >>>> Caused by: >>>> org.apache.flink.runtime.io.network.partition.ProducerFailedException >>>> >>>> TaskManager >>>> >>>> 18:40:35,793 INFO org.apache.flink.streaming.runtime.tasks.StreamTask >>>> - State backend is set to heap memory (checkpoint to jobmanager) >>>> 18:40:35,792 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Source: Read Text File Source -> Flat Map (21/25) switched to RUNNING >>>> 18:40:35,797 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Keyed Aggregation -> Sink: Unnamed (3/25) switched to RUNNING >>>> 18:40:35,806 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>> - Received task Keyed Aggregation -> Sink: Unnamed (4/25) >>>> 18:40:35,814 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Loading JAR files for task Keyed Aggregation -> Sink: Unnamed (4/25) >>>> 18:40:35,816 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Registering task at network: Keyed Aggregation -> Sink: Unnamed (4/25) >>>> [DEPLOYING] >>>> 18:40:35,817 WARN org.apache.flink.streaming.runtime.tasks.StreamTask >>>> - No state backend has been specified, using default state backend (Memory >>>> / >>>> JobManager) >>>> 18:40:35,817 INFO org.apache.flink.streaming.runtime.tasks.StreamTask >>>> - State backend is set to heap memory (checkpoint to jobmanager) >>>> 18:40:35,829 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Keyed Aggregation -> Sink: Unnamed (4/25) switched to RUNNING >>>> 18:43:27,276 WARN akka.remote.RemoteWatcher >>>> - Detected unreachable: [akka.tcp://flink@10.155.208.156:6123] >>>> 18:43:27,323 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>> - TaskManager akka://flink/user/taskmanager disconnects from JobManager >>>> akka.tcp://flink@10.155.208.156:6123/user/jobmanager: JobManager is no >>>> longer reachable >>>> 18:43:27,323 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>> - Cancelling all computations and discarding all cached data. >>>> 18:43:27,325 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Attempting to fail task externally Keyed Aggregation -> Sink: Unnamed >>>> (4/25) >>>> 18:43:27,326 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Keyed Aggregation -> Sink: Unnamed (4/25) switched to FAILED with >>>> exception. >>>> java.lang.Exception: TaskManager akka://flink/user/taskmanager >>>> disconnects from JobManager >>>> akka.tcp://flink@10.155.208.156:6123/user/jobmanager: JobManager is no >>>> longer reachable >>>> at >>>> org.apache.flink.runtime.taskmanager.TaskManager.handleJobManagerDisconnect(TaskManager.scala:826) >>>> at >>>> org.apache.flink.runtime.taskmanager.TaskManager$$anonfun$handleMessage$1.applyOrElse(TaskManager.scala:297) >>>> at >>>> scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) >>>> at >>>> org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:44) >>>> at >>>> scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) >>>> at >>>> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33) >>>> at >>>> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28) >>>> at >>>> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) >>>> at >>>> org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28) >>>> at akka.actor.Actor$class.aroundReceive(Actor.scala:465) >>>> at >>>> org.apache.flink.runtime.taskmanager.TaskManager.aroundReceive(TaskManager.scala:119) >>>> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) >>>> at >>>> akka.actor.dungeon.DeathWatch$class.receivedTerminated(DeathWatch.scala:46) >>>> at akka.actor.ActorCell.receivedTerminated(ActorCell.scala:369) >>>> at akka.actor.ActorCell.autoReceiveMessage(ActorCell.scala:501) >>>> at akka.actor.ActorCell.invoke(ActorCell.scala:486) >>>> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) >>>> at akka.dispatch.Mailbox.run(Mailbox.scala:221) >>>> at akka.dispatch.Mailbox.exec(Mailbox.scala:231) >>>> at >>>> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) >>>> at >>>> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) >>>> at >>>> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) >>>> at >>>> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) >>>> 18:43:27,332 INFO org.apache.flink.runtime.taskmanager.Task >>>> - Triggering cancellation of task code Keyed Aggregation -> Sink: Unnamed >>>> (4/25) (a7b8e27e01d688bf05731c5c1ac9c85a). >>>> >>>> From the FAQ I found it is something to do with Garbage Collection >>>> stalls. Could you throw some light here as to how this could be solved? >>>> >>>> Kind Regards, >>>> Ravinder Kaur >>>> >>>> >>>> On Tue, Mar 15, 2016 at 5:21 PM, Ravinder Kaur <neetu0...@gmail.com> >>>> wrote: >>>>> >>>>> Hello, >>>>> >>>>> Thank you. Error logs were created in the flink directory separately on >>>>> these machines called hs_err_pid.log and these suggested that there was >>>>> insufficient memmory on these machines to allocate. >>>>> >>>>> I resized the memory on these machines and now am able to run the jobs >>>>> error-free. >>>>> >>>>> Kind Regards, >>>>> Ravinder Kaur >>>>> >>>>> On Tue, Mar 15, 2016 at 4:48 PM, Till Rohrmann <trohrm...@apache.org> >>>>> wrote: >>>>>> >>>>>> Have you checked the logs? >>>>>> >>>>>> Cheers, >>>>>> Till >>>>>> >>>>>> On Tue, Mar 15, 2016 at 4:42 PM, Ravinder Kaur <neetu0...@gmail.com> >>>>>> wrote: >>>>>>> >>>>>>> Hello, >>>>>>> >>>>>>> Can anyone suggest the cause for the TaskManagers not starting up? I >>>>>>> have checked all the cluster configurations and nothing has changed nor >>>>>>> wrong. I'm unable to find out why the taskmanagers do not start up. The >>>>>>> startup script also runs normally saying that all TM processes were >>>>>>> started >>>>>>> up. But there is no TM process running on worker nodes. >>>>>>> >>>>>>> Only when cluster is stopped there is info that "No taskmanager >>>>>>> daemon is running anymore on worker node" >>>>>>> >>>>>>> Kind Regards, >>>>>>> Ravinder >>>>>>> >>>>>>> >>>>>>> >>>>>>> On Tue, Mar 15, 2016 at 12:35 PM, Ravinder Kaur <neetu0...@gmail.com> >>>>>>> wrote: >>>>>>>> >>>>>>>> Update: >>>>>>>> >>>>>>>> I restarted the cluster by assinging 50GB memmory to >>>>>>>> taskmanager.heap.mb and now 3 of the TMs that previously did not get >>>>>>>> stopped >>>>>>>> now do not start up. >>>>>>>> >>>>>>>> Kind Regards, >>>>>>>> Ravinder >>>>>>>> >>>>>>>> >>>>>>>> On Tue, Mar 15, 2016 at 12:32 PM, Ravinder Kaur >>>>>>>> <neetu0...@gmail.com> wrote: >>>>>>>>> >>>>>>>>> Hi Till, >>>>>>>>> >>>>>>>>> I had stopped the cluster using bin/stop-cluster.sh after my jobs >>>>>>>>> got cancelled. After this I checked all TM machines if the processes >>>>>>>>> were >>>>>>>>> killed but on 4 machines it was still running. I ran the shell script >>>>>>>>> again >>>>>>>>> but it said No taskmanager is running on the machines. Then I had to >>>>>>>>> manually kill the TaskManager processes on the each of the 4 machines >>>>>>>>> explicitly. >>>>>>>>> >>>>>>>>> I have now stumbled upon the correct log files. Sorry I had not >>>>>>>>> noticed this before. This is the log file of one of the Taskmanagers >>>>>>>>> that >>>>>>>>> got disassociated from the JM. >>>>>>>>> >>>>>>>>> 08:51:26,916 WARN org.apache.hadoop.util.NativeCodeLoader >>>>>>>>> - Unable to load native-hadoop library for your platform... using >>>>>>>>> builtin-java classes where applicable >>>>>>>>> 08:51:27,331 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - >>>>>>>>> -------------------------------------------------------------------------------- >>>>>>>>> 08:51:27,331 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Starting TaskManager (Version: 0.10.1, Rev:2e9b231, >>>>>>>>> Date:22.11.2015 @ >>>>>>>>> 12:41:12 CET) >>>>>>>>> 08:51:27,332 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Current user: flink >>>>>>>>> 08:51:27,332 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.7/24.91-b01 >>>>>>>>> 08:51:27,332 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Maximum heap size: 990 MiBytes >>>>>>>>> 08:51:27,332 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - JAVA_HOME: /usr/lib/jvm/java-1.7.0-openjdk-amd64 >>>>>>>>> 08:51:27,337 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Hadoop version: 2.7.0 >>>>>>>>> 08:51:27,341 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - JVM Options: >>>>>>>>> 08:51:27,341 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - -XX:+UseConcMarkSweepGC >>>>>>>>> 08:51:27,341 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - -XX:+CMSClassUnloadingEnabled >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - -Xms1024M >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - -Xmx1024M >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - -XX:MaxDirectMemorySize=8388607T >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - -XX:MaxPermSize=256m >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - >>>>>>>>> -Dlog.file=/home/flink/flink-0.10.1/log/flink-flink-taskmanager-0-vm-10-155-208-137.cloud.mwn.de.log >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - >>>>>>>>> -Dlog4j.configuration=file:/home/flink/flink-0.10.1/conf/log4j.properties >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - >>>>>>>>> -Dlogback.configurationFile=file:/home/flink/flink-0.10.1/conf/logback.xml >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Program Arguments: >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - --configDir >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - /home/flink/flink-0.10.1/conf >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - --streamingMode >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - streaming >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Classpath: >>>>>>>>> /home/flink/flink-0.10.1/lib/flink-dist_2.11-0.10.1.jar:/home/flink/flink-0.10.1/lib/flink-python_2.11-0.10.1.jar:/home/flink/flink-0.10.1/lib/log4j-1.2.17.jar:/home/flink/flink-0.10.1/lib/slf4j-log4j12-1.7.7.jar:/usr/lib/jvm/java-1.7.0-openjdk-amd64/lib/tools.jar:: >>>>>>>>> 08:51:27,342 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - >>>>>>>>> -------------------------------------------------------------------------------- >>>>>>>>> 08:51:27,349 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Maximum number of open file descriptors is 4096 >>>>>>>>> 08:51:27,378 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Loading configuration from /home/flink/flink-0.10.1/conf >>>>>>>>> 08:51:27,457 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Security is not enabled. Starting non-authenticated TaskManager. >>>>>>>>> 08:51:27,573 INFO >>>>>>>>> org.apache.flink.runtime.util.LeaderRetrievalUtils - >>>>>>>>> Trying to >>>>>>>>> select the network interface and address to use by connecting to the >>>>>>>>> leading >>>>>>>>> JobManager. >>>>>>>>> 08:51:27,574 INFO >>>>>>>>> org.apache.flink.runtime.util.LeaderRetrievalUtils - >>>>>>>>> TaskManager >>>>>>>>> will try to connect for 10000 milliseconds before falling back to >>>>>>>>> heuristics >>>>>>>>> 08:51:27,577 INFO org.apache.flink.runtime.net.ConnectionUtils >>>>>>>>> - Retrieved new target address /10.155.208.156:6123. >>>>>>>>> 08:51:27,606 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - TaskManager will use hostname/address >>>>>>>>> 'vm-10-155-208-137.cloud.mwn.de' >>>>>>>>> (10.155.208.137) for communication. >>>>>>>>> 08:51:27,607 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Starting TaskManager in streaming mode STREAMING >>>>>>>>> 08:51:27,607 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Starting TaskManager actor system at 10.155.208.137:0 >>>>>>>>> 08:51:28,499 INFO akka.event.slf4j.Slf4jLogger >>>>>>>>> - Slf4jLogger started >>>>>>>>> 08:51:28,587 INFO Remoting >>>>>>>>> - Starting remoting >>>>>>>>> 08:51:29,079 INFO Remoting >>>>>>>>> - Remoting started; listening on addresses >>>>>>>>> :[akka.tcp://flink@10.155.208.137:41096] >>>>>>>>> 08:51:29,084 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Starting TaskManager actor >>>>>>>>> 08:51:29,114 INFO >>>>>>>>> org.apache.flink.runtime.io.network.netty.NettyConfig - >>>>>>>>> NettyConfig >>>>>>>>> [server address: vm-10-155-208-137.cloud.mwn.de/10.155.208.137, >>>>>>>>> server port: >>>>>>>>> 42988, memory segment size (bytes): 32768, transport type: NIO, >>>>>>>>> number of >>>>>>>>> server threads: 0 (use Netty's default), number of client threads: 0 >>>>>>>>> (use >>>>>>>>> Netty's default), server connect backlog: 0 (use Netty's default), >>>>>>>>> client >>>>>>>>> connect timeout (sec): 120, send/receive buffer size (bytes): 0 (use >>>>>>>>> Netty's >>>>>>>>> default)] >>>>>>>>> 08:51:29,118 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Messages between TaskManager and JobManager have a max timeout of >>>>>>>>> 100000 >>>>>>>>> milliseconds >>>>>>>>> 08:51:29,150 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Temporary file directory '/tmp': total 4 GB, usable 1 GB (25.00% >>>>>>>>> usable) >>>>>>>>> 08:51:29,191 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). >>>>>>>>> 08:51:29,286 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Using 0.5 of the currently free heap space for Flink managed heap >>>>>>>>> memory >>>>>>>>> (455 MB). >>>>>>>>> 08:51:29,433 INFO >>>>>>>>> org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O >>>>>>>>> manager >>>>>>>>> uses directory /tmp/flink-io-6892942e-0f4a-4564-87b3-eab3406022c0 for >>>>>>>>> spill >>>>>>>>> files. >>>>>>>>> 08:51:29,446 INFO org.apache.flink.runtime.filecache.FileCache >>>>>>>>> - User file cache uses directory >>>>>>>>> /tmp/flink-dist-cache-2b1b9ee0-714e-455c-b405-011b8b5a2bdc >>>>>>>>> 08:51:29,836 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Starting TaskManager actor at >>>>>>>>> akka://flink/user/taskmanager#-215796751. >>>>>>>>> 08:51:29,836 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - TaskManager data connection information: >>>>>>>>> vm-10-155-208-137.cloud.mwn.de >>>>>>>>> (dataPort=42988) >>>>>>>>> 08:51:29,836 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - TaskManager has 4 task slot(s). >>>>>>>>> 08:51:29,838 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Memory usage stats: [HEAP: 102/990/990 MB, NON HEAP: 24/37/304 MB >>>>>>>>> (used/committed/max)] >>>>>>>>> 08:51:29,850 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Trying to register at JobManager >>>>>>>>> akka.tcp://flink@10.155.208.156:6123/user/jobmanager (attempt 1, >>>>>>>>> timeout: >>>>>>>>> 500 milliseconds) >>>>>>>>> 08:51:30,042 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Successful registration at JobManager >>>>>>>>> (akka.tcp://flink@10.155.208.156:6123/user/jobmanager), starting >>>>>>>>> network >>>>>>>>> stack and library cache. >>>>>>>>> 08:51:30,682 INFO >>>>>>>>> org.apache.flink.runtime.io.network.netty.NettyClient - >>>>>>>>> Successful >>>>>>>>> initialization (took 136 ms). >>>>>>>>> 08:51:30,763 INFO >>>>>>>>> org.apache.flink.runtime.io.network.netty.NettyServer - >>>>>>>>> Successful >>>>>>>>> initialization (took 81 ms). Listening on SocketAddress >>>>>>>>> /10.155.208.137:42988. >>>>>>>>> 08:51:30,764 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Determined BLOB server address to be /10.155.208.156:36914. >>>>>>>>> Starting BLOB >>>>>>>>> cache. >>>>>>>>> 08:51:30,770 INFO org.apache.flink.runtime.blob.BlobCache >>>>>>>>> - Created BLOB cache storage directory >>>>>>>>> /tmp/blobStore-f40e39a7-f4ef-49e4-b082-a07a69f8b5c5 >>>>>>>>> 08:52:33,190 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Received task Source: Read Text File Source -> Flat Map (6/25) >>>>>>>>> 08:52:33,191 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Loading JAR files for task Source: Read Text File Source -> Flat Map >>>>>>>>> (6/25) >>>>>>>>> 08:52:33,192 INFO org.apache.flink.runtime.blob.BlobCache >>>>>>>>> - Downloading 4c0984b81f71e4a8d15b9162415af4c237f7b1be from >>>>>>>>> /10.155.208.156:36914 >>>>>>>>> 08:52:33,195 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Received task Source: Read Text File Source -> Flat Map (13/25) >>>>>>>>> 08:52:33,195 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Loading JAR files for task Source: Read Text File Source -> Flat Map >>>>>>>>> (13/25) >>>>>>>>> 08:52:33,198 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Received task Source: Read Text File Source -> Flat Map (20/25) >>>>>>>>> 08:52:33,198 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Loading JAR files for task Source: Read Text File Source -> Flat Map >>>>>>>>> (20/25) >>>>>>>>> 08:52:33,200 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Received task Source: Read Text File Source -> Flat Map (24/25) >>>>>>>>> 08:52:33,200 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Loading JAR files for task Source: Read Text File Source -> Flat Map >>>>>>>>> (24/25) >>>>>>>>> 08:52:33,261 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Registering task at network: Source: Read Text File Source -> Flat >>>>>>>>> Map >>>>>>>>> (6/25) [DEPLOYING] >>>>>>>>> 08:52:33,261 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Registering task at network: Source: Read Text File Source -> Flat >>>>>>>>> Map >>>>>>>>> (24/25) [DEPLOYING] >>>>>>>>> 08:52:33,261 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Registering task at network: Source: Read Text File Source -> Flat >>>>>>>>> Map >>>>>>>>> (13/25) [DEPLOYING] >>>>>>>>> 08:52:33,261 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Registering task at network: Source: Read Text File Source -> Flat >>>>>>>>> Map >>>>>>>>> (20/25) [DEPLOYING] >>>>>>>>> 08:52:33,275 WARN >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - No >>>>>>>>> state >>>>>>>>> backend has been specified, using default state backend (Memory / >>>>>>>>> JobManager) >>>>>>>>> 08:52:33,276 INFO >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - State >>>>>>>>> backend is set to heap memory (checkpoint to jobmanager) >>>>>>>>> 08:52:33,276 WARN >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - No >>>>>>>>> state >>>>>>>>> backend has been specified, using default state backend (Memory / >>>>>>>>> JobManager) >>>>>>>>> 08:52:33,277 INFO >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - State >>>>>>>>> backend is set to heap memory (checkpoint to jobmanager) >>>>>>>>> 08:52:33,276 WARN >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - No >>>>>>>>> state >>>>>>>>> backend has been specified, using default state backend (Memory / >>>>>>>>> JobManager) >>>>>>>>> 08:52:33,277 INFO >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - State >>>>>>>>> backend is set to heap memory (checkpoint to jobmanager) >>>>>>>>> 08:52:33,276 WARN >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - No >>>>>>>>> state >>>>>>>>> backend has been specified, using default state backend (Memory / >>>>>>>>> JobManager) >>>>>>>>> 08:52:33,277 INFO >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - State >>>>>>>>> backend is set to heap memory (checkpoint to jobmanager) >>>>>>>>> 08:52:33,502 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Source: Read Text File Source -> Flat Map (24/25) switched to >>>>>>>>> RUNNING >>>>>>>>> 08:52:33,502 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Source: Read Text File Source -> Flat Map (20/25) switched to >>>>>>>>> RUNNING >>>>>>>>> 08:52:33,505 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Source: Read Text File Source -> Flat Map (13/25) switched to >>>>>>>>> RUNNING >>>>>>>>> 08:52:33,505 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Source: Read Text File Source -> Flat Map (6/25) switched to RUNNING >>>>>>>>> 08:52:34,118 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Received task Keyed Aggregation -> Sink: Unnamed (24/25) >>>>>>>>> 08:52:34,121 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Loading JAR files for task Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (24/25) >>>>>>>>> 08:52:34,149 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Registering task at network: Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (24/25) >>>>>>>>> [DEPLOYING] >>>>>>>>> 08:52:34,150 WARN >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - No >>>>>>>>> state >>>>>>>>> backend has been specified, using default state backend (Memory / >>>>>>>>> JobManager) >>>>>>>>> 08:52:34,150 INFO >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - State >>>>>>>>> backend is set to heap memory (checkpoint to jobmanager) >>>>>>>>> 08:52:34,166 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Received task Keyed Aggregation -> Sink: Unnamed (21/25) >>>>>>>>> 08:52:34,186 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Loading JAR files for task Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (21/25) >>>>>>>>> 08:52:34,186 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Registering task at network: Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (21/25) >>>>>>>>> [DEPLOYING] >>>>>>>>> 08:52:34,208 WARN >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - No >>>>>>>>> state >>>>>>>>> backend has been specified, using default state backend (Memory / >>>>>>>>> JobManager) >>>>>>>>> 08:52:34,226 INFO >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - State >>>>>>>>> backend is set to heap memory (checkpoint to jobmanager) >>>>>>>>> 08:52:34,239 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Received task Keyed Aggregation -> Sink: Unnamed (23/25) >>>>>>>>> 08:52:34,250 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Loading JAR files for task Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (23/25) >>>>>>>>> 08:52:34,272 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Registering task at network: Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (23/25) >>>>>>>>> [DEPLOYING] >>>>>>>>> 08:52:34,150 WARN >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - No >>>>>>>>> state >>>>>>>>> backend has been specified, using default state backend (Memory / >>>>>>>>> JobManager) >>>>>>>>> 08:52:34,150 INFO >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - State >>>>>>>>> backend is set to heap memory (checkpoint to jobmanager) >>>>>>>>> 08:52:34,166 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Received task Keyed Aggregation -> Sink: Unnamed (21/25) >>>>>>>>> 08:52:34,186 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Loading JAR files for task Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (21/25) >>>>>>>>> 08:52:34,186 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Registering task at network: Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (21/25) >>>>>>>>> [DEPLOYING] >>>>>>>>> 08:52:34,208 WARN >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - No >>>>>>>>> state >>>>>>>>> backend has been specified, using default state backend (Memory / >>>>>>>>> JobManager) >>>>>>>>> 08:52:34,226 INFO >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - State >>>>>>>>> backend is set to heap memory (checkpoint to jobmanager) >>>>>>>>> 08:52:34,239 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Received task Keyed Aggregation -> Sink: Unnamed (23/25) >>>>>>>>> 08:52:34,250 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Loading JAR files for task Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (23/25) >>>>>>>>> 08:52:34,272 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Registering task at network: Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (23/25) >>>>>>>>> [DEPLOYING] >>>>>>>>> 08:52:34,272 WARN >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - No >>>>>>>>> state >>>>>>>>> backend has been specified, using default state backend (Memory / >>>>>>>>> JobManager) >>>>>>>>> 08:52:34,272 INFO >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - State >>>>>>>>> backend is set to heap memory (checkpoint to jobmanager) >>>>>>>>> 08:52:34,366 INFO org.apache.flink.runtime.taskmanager.TaskManager >>>>>>>>> - Received task Keyed Aggregation -> Sink: Unnamed (25/25) >>>>>>>>> 08:52:34,374 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Loading JAR files for task Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (25/25) >>>>>>>>> 08:52:34,389 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Registering task at network: Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (25/25) >>>>>>>>> [DEPLOYING] >>>>>>>>> 08:52:34,389 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Keyed Aggregation -> Sink: Unnamed (24/25) switched to RUNNING >>>>>>>>> 08:52:34,389 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Keyed Aggregation -> Sink: Unnamed (21/25) switched to RUNNING >>>>>>>>> 08:52:34,389 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Keyed Aggregation -> Sink: Unnamed (23/25) switched to RUNNING >>>>>>>>> 08:52:34,423 WARN >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - No >>>>>>>>> state >>>>>>>>> backend has been specified, using default state backend (Memory / >>>>>>>>> JobManager) >>>>>>>>> 08:52:34,424 INFO >>>>>>>>> org.apache.flink.streaming.runtime.tasks.StreamTask - State >>>>>>>>> backend is set to heap memory (checkpoint to jobmanager) >>>>>>>>> 08:52:34,451 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Keyed Aggregation -> Sink: Unnamed (25/25) switched to RUNNING >>>>>>>>> 09:13:01,822 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Keyed Aggregation -> Sink: Unnamed (24/25) switched to FAILED with >>>>>>>>> exception. >>>>>>>>> 09:22:56,768 ERROR org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - FATAL - exception in task exception handler >>>>>>>>> 09:23:27,729 INFO org.apache.flink.runtime.taskmanager.Task >>>>>>>>> - Freeing task resources for Keyed Aggregation -> Sink: Unnamed >>>>>>>>> (24/25) >>>>>>>>> >>>>>>>>> Log of JobManager during Job Execution >>>>>>>>> >>>>>>>>> 08:51:11,911 WARN org.apache.hadoop.util.NativeCodeLoader >>>>>>>>> - Unable to load native-hadoop library for your platform... using >>>>>>>>> builtin-java classes where applicable >>>>>>>>> 08:51:12,228 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - >>>>>>>>> -------------------------------------------------------------------------------- >>>>>>>>> 08:51:12,228 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Starting JobManager (Version: 0.10.1, Rev:2e9b231, Date:22.11.2015 >>>>>>>>> @ >>>>>>>>> 12:41:12 CET) >>>>>>>>> 08:51:12,228 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Current user: flink >>>>>>>>> 08:51:12,228 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.7/24.95-b01 >>>>>>>>> 08:51:12,228 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Maximum heap size: 246 MiBytes >>>>>>>>> 08:51:12,228 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - JAVA_HOME: /usr/lib/jvm/java-1.7.0-openjdk-amd64 >>>>>>>>> 08:51:12,241 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Hadoop version: 2.7.0 >>>>>>>>> 08:51:12,241 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - JVM Options: >>>>>>>>> 08:51:12,241 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - -Xms256m >>>>>>>>> 08:51:12,241 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - -Xmx256m >>>>>>>>> 08:51:12,241 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - -XX:MaxPermSize=256m >>>>>>>>> 08:51:12,241 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - >>>>>>>>> -Dlog.file=/home/flink/flink-0.10.1/log/flink-flink-jobmanager-0-vm-10-155-208-156.cloud.mwn.de.log >>>>>>>>> 08:51:12,241 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - >>>>>>>>> -Dlog4j.configuration=file:/home/flink/flink-0.10.1/conf/log4j.properties >>>>>>>>> 08:51:12,241 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - >>>>>>>>> -Dlogback.configurationFile=file:/home/flink/flink-0.10.1/conf/logback.xml >>>>>>>>> 08:51:12,241 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Program Arguments: >>>>>>>>> 08:51:12,241 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - --configDir >>>>>>>>> 08:51:12,241 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - /home/flink/flink-0.10.1/conf >>>>>>>>> 08:51:12,242 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - --executionMode >>>>>>>>> 08:51:12,242 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - cluster >>>>>>>>> 08:51:12,242 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - --streamingMode >>>>>>>>> 08:51:12,242 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - streaming >>>>>>>>> 08:51:12,242 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Classpath: >>>>>>>>> /home/flink/flink-0.10.1/lib/flink-dist_2.11-0.10.1.jar:/home/flink/flink-0.10.1/lib/flink-python_2.11-0.10.1.jar:/home/flink/flink-0.10.1/lib/log4j-1.2.17.jar:/home/flink/flink-0.10.1/lib/slf4j-log4j12-1.7.7.jar::: >>>>>>>>> 08:51:12,242 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - >>>>>>>>> -------------------------------------------------------------------------------- >>>>>>>>> 08:51:12,430 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Loading configuration from /home/flink/flink-0.10.1/conf >>>>>>>>> 08:51:12,451 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Staring JobManager without high-availability >>>>>>>>> 08:51:12,464 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Starting JobManager on 10.155.208.156:6123 with execution mode >>>>>>>>> CLUSTER and >>>>>>>>> streaming mode STREAMING >>>>>>>>> 08:51:12,574 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Security is not enabled. Starting non-authenticated JobManager. >>>>>>>>> 08:51:12,575 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Starting JobManager >>>>>>>>> 08:51:12,575 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Starting JobManager actor system at 10.155.208.156:6123 >>>>>>>>> 08:51:13,253 INFO akka.event.slf4j.Slf4jLogger >>>>>>>>> - Slf4jLogger started >>>>>>>>> 08:51:13,362 INFO Remoting >>>>>>>>> - Starting remoting >>>>>>>>> 08:51:13,668 INFO Remoting >>>>>>>>> - Remoting started; listening on addresses >>>>>>>>> :[akka.tcp://flink@10.155.208.156:6123] >>>>>>>>> 08:51:13,681 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Starting JobManger web frontend >>>>>>>>> 08:51:13,735 INFO >>>>>>>>> org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Using >>>>>>>>> directory /tmp/flink-web-e5a124e6-2c92-4f19-803c-7e2f4a9e398d for the >>>>>>>>> web >>>>>>>>> interface files >>>>>>>>> 08:51:13,736 INFO >>>>>>>>> org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - >>>>>>>>> Serving job >>>>>>>>> manager log from >>>>>>>>> /home/flink/flink-0.10.1/log/flink-flink-jobmanager-0-vm-10-155-208-156.cloud.mwn.de.log >>>>>>>>> 08:51:13,737 INFO >>>>>>>>> org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - >>>>>>>>> Serving job >>>>>>>>> manager stdout from >>>>>>>>> /home/flink/flink-0.10.1/log/flink-flink-jobmanager-0-vm-10-155-208-156.cloud.mwn.de.out >>>>>>>>> 08:51:14,169 INFO >>>>>>>>> org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Web >>>>>>>>> frontend >>>>>>>>> listening at 0:0:0:0:0:0:0:0:8081 >>>>>>>>> 08:51:14,170 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Starting JobManager actor >>>>>>>>> 08:51:14,178 INFO org.apache.flink.runtime.blob.BlobServer >>>>>>>>> - Created BLOB server storage directory >>>>>>>>> /tmp/blobStore-a2f6d78f-c650-430d-8cd2-dde7d65b8463 >>>>>>>>> 08:51:14,180 INFO org.apache.flink.runtime.blob.BlobServer >>>>>>>>> - Started BLOB server at 0.0.0.0:36914 - max concurrent requests: 50 >>>>>>>>> - max >>>>>>>>> backlog: 1000 >>>>>>>>> 08:51:14,227 INFO >>>>>>>>> org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - >>>>>>>>> Starting >>>>>>>>> with JobManager akka.tcp://flink@10.155.208.156:6123/user/jobmanager >>>>>>>>> on port >>>>>>>>> 8081 >>>>>>>>> 08:51:14,227 INFO >>>>>>>>> org.apache.flink.runtime.webmonitor.JobManagerRetriever - New >>>>>>>>> leader >>>>>>>>> reachable under >>>>>>>>> akka.tcp://flink@10.155.208.156:6123/user/jobmanager:null. >>>>>>>>> 08:51:14,230 INFO >>>>>>>>> org.apache.flink.runtime.jobmanager.MemoryArchivist - >>>>>>>>> Started >>>>>>>>> memory archivist akka://flink/user/archive >>>>>>>>> 08:51:14,232 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Starting JobManager at >>>>>>>>> akka.tcp://flink@10.155.208.156:6123/user/jobmanager. >>>>>>>>> 08:51:14,238 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - JobManager akka.tcp://flink@10.155.208.156:6123/user/jobmanager was >>>>>>>>> granted leadership with leader session ID None. >>>>>>>>> 08:51:15,659 INFO >>>>>>>>> org.apache.flink.runtime.instance.InstanceManager - >>>>>>>>> Registered >>>>>>>>> TaskManager at vm-10-155-208-156 >>>>>>>>> (akka.tcp://flink@10.155.208.156:33728/user/taskmanager) as >>>>>>>>> 749bdc28313ae125f292377f3bc46925. Current number of registered hosts >>>>>>>>> is 1. >>>>>>>>> Current number of alive task slots is 3. >>>>>>>>> 08:51:17,670 INFO >>>>>>>>> org.apache.flink.runtime.instance.InstanceManager - >>>>>>>>> Registered >>>>>>>>> TaskManager at vm-10-155-208-157 >>>>>>>>> (akka.tcp://flink@10.155.208.157:33728/user/taskmanager) as >>>>>>>>> 62f658c5f1e690b1dd6c2f0610553916. Current number of registered hosts >>>>>>>>> is 2. >>>>>>>>> Current number of alive task slots is 6. >>>>>>>>> 08:51:18,513 INFO >>>>>>>>> org.apache.flink.runtime.instance.InstanceManager - >>>>>>>>> Registered >>>>>>>>> TaskManager at vm-10-155-208-158 >>>>>>>>> (akka.tcp://flink@10.155.208.158:33728/user/taskmanager) as >>>>>>>>> e5e5d4a5a015b0a4636e5a6c1d16be84. Current number of registered hosts >>>>>>>>> is 3. >>>>>>>>> Current number of alive task slots is 9. >>>>>>>>> 08:51:23,684 INFO >>>>>>>>> org.apache.flink.runtime.instance.InstanceManager - >>>>>>>>> Registered >>>>>>>>> TaskManager at slave3 >>>>>>>>> (akka.tcp://flink@10.155.208.135:54516/user/taskmanager) as >>>>>>>>> fbd10bca3c9f82460b4b75bd66810aee. Current number of registered hosts >>>>>>>>> is 4. >>>>>>>>> Current number of alive task slots is 13. >>>>>>>>> 08:51:29,639 INFO >>>>>>>>> org.apache.flink.runtime.instance.InstanceManager - >>>>>>>>> Registered >>>>>>>>> TaskManager at slave2 >>>>>>>>> (akka.tcp://flink@10.155.208.136:43058/user/taskmanager) as >>>>>>>>> c4230ed259af95525dc316040048e7fd. Current number of registered hosts >>>>>>>>> is 5. >>>>>>>>> Current number of alive task slots is 17. >>>>>>>>> 08:51:30,029 INFO >>>>>>>>> org.apache.flink.runtime.instance.InstanceManager - >>>>>>>>> Registered >>>>>>>>> TaskManager at vm-10-155-208-137 >>>>>>>>> (akka.tcp://flink@10.155.208.137:41096/user/taskmanager) as >>>>>>>>> 8ebde78fbee2d2fb7d94f1fd71378431. Current number of registered hosts >>>>>>>>> is 6. >>>>>>>>> Current number of alive task slots is 21. >>>>>>>>> 08:51:40,700 INFO >>>>>>>>> org.apache.flink.runtime.instance.InstanceManager - >>>>>>>>> Registered >>>>>>>>> TaskManager at vm-10-155-208-138 >>>>>>>>> (akka.tcp://flink@10.155.208.138:42222/user/taskmanager) as >>>>>>>>> 831a72dad6fbb533b193820f45bdc5bc. Current number of registered hosts >>>>>>>>> is 7. >>>>>>>>> Current number of alive task slots is 25. >>>>>>>>> 08:52:33,050 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Submitting job aeb1eca3a4feefa6fd00b599c0c783d4 (WordCount from >>>>>>>>> SocketTextStream Example). >>>>>>>>> 08:52:33,117 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Scheduling job aeb1eca3a4feefa6fd00b599c0c783d4 (WordCount from >>>>>>>>> SocketTextStream Example). >>>>>>>>> 08:52:33,119 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Status of job aeb1eca3a4feefa6fd00b599c0c783d4 (WordCount from >>>>>>>>> SocketTextStream Example) changed to RUNNING. >>>>>>>>> 08:52:33,122 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (1/25) (bce7a3459fd80414266a6ac891b04551) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,130 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (1/25) (bce7a3459fd80414266a6ac891b04551) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,131 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (1/25) (attempt #0) to >>>>>>>>> vm-10-155-208-156 >>>>>>>>> 08:52:33,134 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (2/25) (b67073687787b804d628eb6482fa2a30) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,136 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (2/25) (b67073687787b804d628eb6482fa2a30) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,137 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (2/25) (attempt #0) to >>>>>>>>> vm-10-155-208-157 >>>>>>>>> 08:52:33,142 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (3/25) (07a2adef7d57cdd5081dd88533bb6631) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,143 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (3/25) (07a2adef7d57cdd5081dd88533bb6631) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,143 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (3/25) (attempt #0) to >>>>>>>>> vm-10-155-208-158 >>>>>>>>> 08:52:33,144 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (4/25) (da342b5a369f9da0deaffac409640210) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,145 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (4/25) (da342b5a369f9da0deaffac409640210) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,145 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (4/25) (attempt #0) to >>>>>>>>> slave3 >>>>>>>>> 08:52:33,151 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (5/25) (0edf387c2b8f7f3e6925192bc7e295ee) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,152 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (5/25) (0edf387c2b8f7f3e6925192bc7e295ee) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,152 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (5/25) (attempt #0) to >>>>>>>>> slave2 >>>>>>>>> 08:52:33,154 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (6/25) (de554cfcbc7f7ecf924fd3bfd1f951ce) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,155 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (6/25) (de554cfcbc7f7ecf924fd3bfd1f951ce) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,155 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (6/25) (attempt #0) to >>>>>>>>> vm-10-155-208-137 >>>>>>>>> 08:52:33,156 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (7/25) (386211d919b02137f42e4df3fefb9619) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,158 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (7/25) (386211d919b02137f42e4df3fefb9619) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,158 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (7/25) (attempt #0) to >>>>>>>>> vm-10-155-208-138 >>>>>>>>> 08:52:33,159 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (8/25) (38f8b7ded3af389ccfc3a92f74761c1b) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,160 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (8/25) (38f8b7ded3af389ccfc3a92f74761c1b) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,160 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (8/25) (attempt #0) to >>>>>>>>> vm-10-155-208-156 >>>>>>>>> 08:52:33,161 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (9/25) (88259e334ed2c8ea47b64f4f8083ae83) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,162 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (9/25) (88259e334ed2c8ea47b64f4f8083ae83) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,162 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (9/25) (attempt #0) to >>>>>>>>> vm-10-155-208-157 >>>>>>>>> 08:52:33,164 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (10/25) >>>>>>>>> (5f1e48cb807bfc4f837d0d2587d071e7) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,165 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (10/25) >>>>>>>>> (5f1e48cb807bfc4f837d0d2587d071e7) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,165 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (10/25) (attempt #0) to >>>>>>>>> vm-10-155-208-158 >>>>>>>>> 08:52:33,166 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (11/25) >>>>>>>>> (39e9a6f6c11427bf9024fcf6b88dbd3e) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,167 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (11/25) >>>>>>>>> (39e9a6f6c11427bf9024fcf6b88dbd3e) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,168 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (11/25) (attempt #0) to >>>>>>>>> slave3 >>>>>>>>> 08:52:33,169 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (12/25) >>>>>>>>> (f25aa9d229f5df70aafa40fa59d88264) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,170 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (12/25) >>>>>>>>> (f25aa9d229f5df70aafa40fa59d88264) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,170 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (12/25) (attempt #0) to >>>>>>>>> slave2 >>>>>>>>> 08:52:33,171 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (13/25) >>>>>>>>> (1e572ad1eab41b5f219d8ddd3d544699) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,172 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (13/25) >>>>>>>>> (1e572ad1eab41b5f219d8ddd3d544699) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,172 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (13/25) (attempt #0) to >>>>>>>>> vm-10-155-208-137 >>>>>>>>> 08:52:33,173 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (14/25) >>>>>>>>> (10a5223d3d716bca1a50853f0efcab02) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,174 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (14/25) >>>>>>>>> (10a5223d3d716bca1a50853f0efcab02) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,175 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (14/25) (attempt #0) to >>>>>>>>> vm-10-155-208-138 >>>>>>>>> 08:52:33,176 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (15/25) >>>>>>>>> (c8b82db126393db46682e036fd6f8527) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,177 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (15/25) >>>>>>>>> (c8b82db126393db46682e036fd6f8527) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,177 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (15/25) (attempt #0) to >>>>>>>>> vm-10-155-208-156 >>>>>>>>> 08:52:33,178 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (16/25) >>>>>>>>> (7339669af58d2f65f8ea69cb7b318773) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,179 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (16/25) >>>>>>>>> (7339669af58d2f65f8ea69cb7b318773) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,179 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (16/25) (attempt #0) to >>>>>>>>> vm-10-155-208-157 >>>>>>>>> 08:52:33,181 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (17/25) >>>>>>>>> (da4388c09a9874e7b7afc979a7af79b8) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,184 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (17/25) >>>>>>>>> (da4388c09a9874e7b7afc979a7af79b8) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,184 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (17/25) (attempt #0) to >>>>>>>>> vm-10-155-208-158 >>>>>>>>> 08:52:33,187 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (18/25) >>>>>>>>> (498d68b92dbb4c8a2a7a1db344fe01a8) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,188 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (18/25) >>>>>>>>> (498d68b92dbb4c8a2a7a1db344fe01a8) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,189 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (18/25) (attempt #0) to >>>>>>>>> slave3 >>>>>>>>> 08:52:33,193 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (19/25) >>>>>>>>> (f7fcba6ec0608360f363665afd99fb5d) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,194 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (19/25) >>>>>>>>> (f7fcba6ec0608360f363665afd99fb5d) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,194 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (19/25) (attempt #0) to >>>>>>>>> slave2 >>>>>>>>> 08:52:33,195 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (20/25) >>>>>>>>> (fd5b27a36b4f09c2191fbf4c23ab61d1) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,195 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (20/25) >>>>>>>>> (fd5b27a36b4f09c2191fbf4c23ab61d1) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,196 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (20/25) (attempt #0) to >>>>>>>>> vm-10-155-208-137 >>>>>>>>> 08:52:33,196 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (21/25) >>>>>>>>> (3827b667c8e997c9e7e16ad0018cc767) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,200 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (21/25) >>>>>>>>> (3827b667c8e997c9e7e16ad0018cc767) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,201 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (21/25) (attempt #0) to >>>>>>>>> vm-10-155-208-138 >>>>>>>>> 08:52:33,202 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (22/25) >>>>>>>>> (4cbe7fa6850e61d695c3ac2a49995e60) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,202 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (22/25) >>>>>>>>> (4cbe7fa6850e61d695c3ac2a49995e60) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,203 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (22/25) (attempt #0) to >>>>>>>>> slave3 >>>>>>>>> 08:52:33,203 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (23/25) >>>>>>>>> (1450b59a7088dd0ae6c6720d31839167) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,204 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (23/25) >>>>>>>>> (1450b59a7088dd0ae6c6720d31839167) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,204 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (23/25) (attempt #0) to >>>>>>>>> slave2 >>>>>>>>> 08:52:33,205 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (24/25) >>>>>>>>> (6766fa50924793cec3a4d1234bb62c06) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,206 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (24/25) >>>>>>>>> (6766fa50924793cec3a4d1234bb62c06) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,206 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (24/25) (attempt #0) to >>>>>>>>> vm-10-155-208-137 >>>>>>>>> 08:52:33,207 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (25/25) >>>>>>>>> (2ce8063004c80a4d16104e873f82132e) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,208 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (25/25) >>>>>>>>> (2ce8063004c80a4d16104e873f82132e) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,208 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Source: Read Text File Source -> Flat Map (25/25) (attempt #0) to >>>>>>>>> vm-10-155-208-138 >>>>>>>>> 08:52:33,209 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (1/25) (9dee3c4d890f01233d5c95f15a9b3c96) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,210 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (1/25) (9dee3c4d890f01233d5c95f15a9b3c96) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,211 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (1/25) (attempt #0) to >>>>>>>>> vm-10-155-208-157 >>>>>>>>> 08:52:33,245 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (2/25) (fbdd9e6f0a6ab2f5441afa4b171a8db3) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,256 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (2/25) (fbdd9e6f0a6ab2f5441afa4b171a8db3) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,256 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (2/25) (attempt #0) to >>>>>>>>> vm-10-155-208-157 >>>>>>>>> 08:52:33,316 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (3/25) (bbd7f74a8a57288a2e8a5c459418d6b3) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,316 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (3/25) (bbd7f74a8a57288a2e8a5c459418d6b3) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,317 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (3/25) (attempt #0) to >>>>>>>>> vm-10-155-208-157 >>>>>>>>> 08:52:33,333 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (4/25) (6b71db98a7a0f2fa53da59f2f8a21cce) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,334 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (4/25) (6b71db98a7a0f2fa53da59f2f8a21cce) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,335 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (4/25) (attempt #0) to >>>>>>>>> vm-10-155-208-156 >>>>>>>>> 08:52:33,354 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (5/25) (011b449fae3ff4b9769c7d75b1cc34ef) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,359 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (5/25) (011b449fae3ff4b9769c7d75b1cc34ef) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,360 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (5/25) (attempt #0) to >>>>>>>>> vm-10-155-208-156 >>>>>>>>> 08:52:33,380 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (6/25) (61dec00d3e2736d3178d22f7c5c9e499) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,381 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (6/25) (61dec00d3e2736d3178d22f7c5c9e499) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,381 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (6/25) (attempt #0) to >>>>>>>>> vm-10-155-208-156 >>>>>>>>> 08:52:33,400 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (7/25) (fa434906c2e64e78743049e21494ad08) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,401 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (7/25) (fa434906c2e64e78743049e21494ad08) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,401 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (7/25) (attempt #0) to slave2 >>>>>>>>> 08:52:33,414 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (8/25) (504a1e8018bd16bbc1cdc5474bc5a496) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,415 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (8/25) (504a1e8018bd16bbc1cdc5474bc5a496) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,415 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (8/25) (attempt #0) to slave2 >>>>>>>>> 08:52:33,428 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (9/25) (ca432acdde8ac296ee1b7fa169d80260) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,428 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (9/25) (ca432acdde8ac296ee1b7fa169d80260) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,428 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (9/25) (attempt #0) to slave2 >>>>>>>>> 08:52:33,446 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (10/25) >>>>>>>>> (4ec7d078930d8b31e89bc5bf63964029) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,447 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (10/25) >>>>>>>>> (4ec7d078930d8b31e89bc5bf63964029) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,447 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (10/25) (attempt #0) to slave2 >>>>>>>>> 08:52:33,464 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (11/25) >>>>>>>>> (b6d53055b7787e63cda0ccfe6f1cf67d) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,465 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (11/25) >>>>>>>>> (b6d53055b7787e63cda0ccfe6f1cf67d) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,465 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (11/25) (attempt #0) to >>>>>>>>> vm-10-155-208-158 >>>>>>>>> 08:52:33,489 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (12/25) >>>>>>>>> (78fc3cd38db931784d45e8b6a0ecd719) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,502 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> local split to host vm-10-155-208-156 >>>>>>>>> 08:52:33,516 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> local split to host vm-10-155-208-156 >>>>>>>>> 08:52:33,517 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> local split to host vm-10-155-208-156 >>>>>>>>> 08:52:33,517 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (12/25) >>>>>>>>> (78fc3cd38db931784d45e8b6a0ecd719) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,517 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (12/25) (attempt #0) to >>>>>>>>> vm-10-155-208-158 >>>>>>>>> 08:52:33,539 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-138 >>>>>>>>> 08:52:33,540 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (21/25) >>>>>>>>> (3827b667c8e997c9e7e16ad0018cc767) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,541 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (7/25) (386211d919b02137f42e4df3fefb9619) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,542 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (14/25) >>>>>>>>> (10a5223d3d716bca1a50853f0efcab02) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,546 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (25/25) >>>>>>>>> (2ce8063004c80a4d16104e873f82132e) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,579 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (13/25) >>>>>>>>> (3d2f2e956e1f5c3518c222f68b37698a) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,580 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (13/25) >>>>>>>>> (3d2f2e956e1f5c3518c222f68b37698a) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,580 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (13/25) (attempt #0) to >>>>>>>>> vm-10-155-208-158 >>>>>>>>> 08:52:33,590 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-138 >>>>>>>>> 08:52:33,590 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-138 >>>>>>>>> 08:52:33,591 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-138 >>>>>>>>> 08:52:33,592 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (16/25) >>>>>>>>> (7339669af58d2f65f8ea69cb7b318773) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,592 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (9/25) (88259e334ed2c8ea47b64f4f8083ae83) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,603 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-157 >>>>>>>>> 08:52:33,603 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-157 >>>>>>>>> 08:52:33,604 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-157 >>>>>>>>> 08:52:33,606 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (3/25) (bbd7f74a8a57288a2e8a5c459418d6b3) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,607 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (1/25) (9dee3c4d890f01233d5c95f15a9b3c96) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,608 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (2/25) (fbdd9e6f0a6ab2f5441afa4b171a8db3) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,618 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-137 >>>>>>>>> 08:52:33,619 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (2/25) (b67073687787b804d628eb6482fa2a30) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,621 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (24/25) >>>>>>>>> (6766fa50924793cec3a4d1234bb62c06) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,622 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (13/25) >>>>>>>>> (1e572ad1eab41b5f219d8ddd3d544699) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,635 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (6/25) (de554cfcbc7f7ecf924fd3bfd1f951ce) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,637 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (20/25) >>>>>>>>> (fd5b27a36b4f09c2191fbf4c23ab61d1) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,645 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-137 >>>>>>>>> 08:52:33,647 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-137 >>>>>>>>> 08:52:33,648 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-137 >>>>>>>>> 08:52:33,651 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (14/25) >>>>>>>>> (c1192e402ab4a018b67f2c74f4286e13) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,652 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (14/25) >>>>>>>>> (c1192e402ab4a018b67f2c74f4286e13) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,652 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (14/25) (attempt #0) to >>>>>>>>> vm-10-155-208-138 >>>>>>>>> 08:52:33,656 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (8/25) (38f8b7ded3af389ccfc3a92f74761c1b) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,657 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (15/25) >>>>>>>>> (c8b82db126393db46682e036fd6f8527) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,657 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (1/25) (bce7a3459fd80414266a6ac891b04551) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,667 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host slave2 >>>>>>>>> 08:52:33,667 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host slave2 >>>>>>>>> 08:52:33,668 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (11/25) >>>>>>>>> (39e9a6f6c11427bf9024fcf6b88dbd3e) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,668 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host slave2 >>>>>>>>> 08:52:33,668 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host slave2 >>>>>>>>> 08:52:33,669 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (4/25) (da342b5a369f9da0deaffac409640210) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,669 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (22/25) >>>>>>>>> (4cbe7fa6850e61d695c3ac2a49995e60) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,676 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (18/25) >>>>>>>>> (498d68b92dbb4c8a2a7a1db344fe01a8) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,690 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host slave3 >>>>>>>>> 08:52:33,690 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host slave3 >>>>>>>>> 08:52:33,690 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host slave3 >>>>>>>>> 08:52:33,691 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host slave3 >>>>>>>>> 08:52:33,707 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (4/25) (6b71db98a7a0f2fa53da59f2f8a21cce) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,707 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (5/25) (011b449fae3ff4b9769c7d75b1cc34ef) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,708 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (6/25) (61dec00d3e2736d3178d22f7c5c9e499) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,722 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (15/25) >>>>>>>>> (4666479516b2ffe3c49ad7c027a80ad3) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,723 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (15/25) >>>>>>>>> (4666479516b2ffe3c49ad7c027a80ad3) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,723 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (15/25) (attempt #0) to >>>>>>>>> vm-10-155-208-138 >>>>>>>>> 08:52:33,753 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (16/25) >>>>>>>>> (ac2ef9c1626ccb5bc92893b7f2302727) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,754 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (16/25) >>>>>>>>> (ac2ef9c1626ccb5bc92893b7f2302727) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,754 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (16/25) (attempt #0) to >>>>>>>>> vm-10-155-208-138 >>>>>>>>> 08:52:33,763 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (17/25) >>>>>>>>> (e41bf8f2e7e1034d4aeb993da711994d) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,770 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (17/25) >>>>>>>>> (e41bf8f2e7e1034d4aeb993da711994d) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,770 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (17/25) (attempt #0) to >>>>>>>>> vm-10-155-208-138 >>>>>>>>> 08:52:33,771 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (23/25) >>>>>>>>> (1450b59a7088dd0ae6c6720d31839167) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,772 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (5/25) (0edf387c2b8f7f3e6925192bc7e295ee) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,772 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (12/25) >>>>>>>>> (f25aa9d229f5df70aafa40fa59d88264) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,772 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (7/25) (fa434906c2e64e78743049e21494ad08) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,772 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (8/25) (504a1e8018bd16bbc1cdc5474bc5a496) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,773 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (9/25) (ca432acdde8ac296ee1b7fa169d80260) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,803 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (20/25) >>>>>>>>> (f8243db3aa35c8cc6e725cff575e5dd1) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,800 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (18/25) >>>>>>>>> (100bf52dde6379d11399c02e4b2c0a49) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,798 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (19/25) >>>>>>>>> (f7fcba6ec0608360f363665afd99fb5d) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,838 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (18/25) >>>>>>>>> (100bf52dde6379d11399c02e4b2c0a49) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,838 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (18/25) (attempt #0) to slave3 >>>>>>>>> 08:52:33,847 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (22/25) >>>>>>>>> (4c3bce50b83ec0e56d3e5940879f8efc) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,848 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (22/25) >>>>>>>>> (4c3bce50b83ec0e56d3e5940879f8efc) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,848 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (22/25) (attempt #0) to slave3 >>>>>>>>> 08:52:33,848 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (22/25) >>>>>>>>> (4c3bce50b83ec0e56d3e5940879f8efc) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,848 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (22/25) (attempt #0) to slave3 >>>>>>>>> 08:52:33,775 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (19/25) >>>>>>>>> (b74e7a60547032d269422f8ccfe5b40b) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,792 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (21/25) >>>>>>>>> (c4666c247ddad9d713670f7a84ab3aca) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,786 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (10/25) >>>>>>>>> (4ec7d078930d8b31e89bc5bf63964029) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,866 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (19/25) >>>>>>>>> (b74e7a60547032d269422f8ccfe5b40b) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,834 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (20/25) >>>>>>>>> (f8243db3aa35c8cc6e725cff575e5dd1) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,866 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (19/25) (attempt #0) to slave3 >>>>>>>>> 08:52:33,867 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (20/25) (attempt #0) to slave3 >>>>>>>>> 08:52:33,869 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (23/25) >>>>>>>>> (00dbd5965e361f476dfabd09ad803e66) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,869 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (23/25) >>>>>>>>> (00dbd5965e361f476dfabd09ad803e66) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,869 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (23/25) (attempt #0) to >>>>>>>>> vm-10-155-208-137 >>>>>>>>> 08:52:33,870 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (24/25) >>>>>>>>> (b0cce659eb47fa75d876f280f53eaa68) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,871 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (24/25) >>>>>>>>> (b0cce659eb47fa75d876f280f53eaa68) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,871 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (24/25) (attempt #0) to >>>>>>>>> vm-10-155-208-137 >>>>>>>>> 08:52:33,878 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (25/25) >>>>>>>>> (580c73a4bff8720e996cfdf248b98163) >>>>>>>>> switched from CREATED to SCHEDULED >>>>>>>>> 08:52:33,878 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (25/25) >>>>>>>>> (580c73a4bff8720e996cfdf248b98163) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,878 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (25/25) (attempt #0) to >>>>>>>>> vm-10-155-208-137 >>>>>>>>> 08:52:33,880 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (21/25) >>>>>>>>> (c4666c247ddad9d713670f7a84ab3aca) >>>>>>>>> switched from SCHEDULED to DEPLOYING >>>>>>>>> 08:52:33,880 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Deploying >>>>>>>>> Keyed Aggregation -> Sink: Unnamed (21/25) (attempt #0) to >>>>>>>>> vm-10-155-208-137 >>>>>>>>> 08:52:33,935 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (15/25) >>>>>>>>> (4666479516b2ffe3c49ad7c027a80ad3) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:33,938 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (14/25) >>>>>>>>> (c1192e402ab4a018b67f2c74f4286e13) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,013 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (17/25) >>>>>>>>> (e41bf8f2e7e1034d4aeb993da711994d) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,173 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (16/25) >>>>>>>>> (ac2ef9c1626ccb5bc92893b7f2302727) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,311 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (18/25) >>>>>>>>> (100bf52dde6379d11399c02e4b2c0a49) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,311 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (22/25) >>>>>>>>> (4c3bce50b83ec0e56d3e5940879f8efc) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,312 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (20/25) >>>>>>>>> (f8243db3aa35c8cc6e725cff575e5dd1) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,450 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (24/25) >>>>>>>>> (b0cce659eb47fa75d876f280f53eaa68) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,450 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (21/25) >>>>>>>>> (c4666c247ddad9d713670f7a84ab3aca) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,455 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (23/25) >>>>>>>>> (00dbd5965e361f476dfabd09ad803e66) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,590 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (19/25) >>>>>>>>> (b74e7a60547032d269422f8ccfe5b40b) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,726 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (3/25) (07a2adef7d57cdd5081dd88533bb6631) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,726 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (17/25) >>>>>>>>> (da4388c09a9874e7b7afc979a7af79b8) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,726 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (10/25) >>>>>>>>> (5f1e48cb807bfc4f837d0d2587d071e7) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,727 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-158 >>>>>>>>> 08:52:34,727 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-158 >>>>>>>>> 08:52:34,729 INFO >>>>>>>>> org.apache.flink.api.common.io.LocatableInputSplitAssigner - >>>>>>>>> Assigning >>>>>>>>> remote split to host vm-10-155-208-158 >>>>>>>>> 08:52:34,742 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (13/25) >>>>>>>>> (3d2f2e956e1f5c3518c222f68b37698a) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,742 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (12/25) >>>>>>>>> (78fc3cd38db931784d45e8b6a0ecd719) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,743 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (25/25) >>>>>>>>> (580c73a4bff8720e996cfdf248b98163) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:34,747 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (11/25) >>>>>>>>> (b6d53055b7787e63cda0ccfe6f1cf67d) >>>>>>>>> switched from DEPLOYING to RUNNING >>>>>>>>> 08:52:46,084 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (9/25) (88259e334ed2c8ea47b64f4f8083ae83) >>>>>>>>> switched from RUNNING to FINISHED >>>>>>>>> 08:52:46,750 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (16/25) >>>>>>>>> (7339669af58d2f65f8ea69cb7b318773) >>>>>>>>> switched from RUNNING to FINISHED >>>>>>>>> 08:52:47,138 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (2/25) (b67073687787b804d628eb6482fa2a30) >>>>>>>>> switched from RUNNING to FINISHED >>>>>>>>> 08:52:48,700 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (8/25) (38f8b7ded3af389ccfc3a92f74761c1b) >>>>>>>>> switched from RUNNING to FINISHED >>>>>>>>> 08:52:48,891 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (15/25) >>>>>>>>> (c8b82db126393db46682e036fd6f8527) >>>>>>>>> switched from RUNNING to FINISHED >>>>>>>>> 08:52:49,133 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (10/25) >>>>>>>>> (5f1e48cb807bfc4f837d0d2587d071e7) >>>>>>>>> switched from RUNNING to FINISHED >>>>>>>>> 08:52:49,231 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (17/25) >>>>>>>>> (da4388c09a9874e7b7afc979a7af79b8) >>>>>>>>> switched from RUNNING to FINISHED >>>>>>>>> 08:52:49,239 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (1/25) (bce7a3459fd80414266a6ac891b04551) >>>>>>>>> switched from RUNNING to FINISHED >>>>>>>>> 08:52:49,404 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (3/25) (07a2adef7d57cdd5081dd88533bb6631) >>>>>>>>> switched from RUNNING to FINISHED >>>>>>>>> 08:59:56,690 WARN akka.remote.RemoteWatcher >>>>>>>>> - Detected unreachable: [akka.tcp://flink@10.155.208.138:42222] >>>>>>>>> 08:59:56,696 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Task manager akka.tcp://flink@10.155.208.138:42222/user/taskmanager >>>>>>>>> terminated. >>>>>>>>> 08:59:56,697 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (16/25) >>>>>>>>> (ac2ef9c1626ccb5bc92893b7f2302727) >>>>>>>>> switched from RUNNING to FAILED >>>>>>>>> 08:59:56,705 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (4/25) (da342b5a369f9da0deaffac409640210) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,708 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (5/25) (0edf387c2b8f7f3e6925192bc7e295ee) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,708 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (6/25) (de554cfcbc7f7ecf924fd3bfd1f951ce) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,708 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (7/25) (386211d919b02137f42e4df3fefb9619) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,709 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (11/25) >>>>>>>>> (39e9a6f6c11427bf9024fcf6b88dbd3e) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,709 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (12/25) >>>>>>>>> (f25aa9d229f5df70aafa40fa59d88264) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,709 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (13/25) >>>>>>>>> (1e572ad1eab41b5f219d8ddd3d544699) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,709 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (14/25) >>>>>>>>> (10a5223d3d716bca1a50853f0efcab02) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,709 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (18/25) >>>>>>>>> (498d68b92dbb4c8a2a7a1db344fe01a8) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,709 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (19/25) >>>>>>>>> (f7fcba6ec0608360f363665afd99fb5d) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,710 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (20/25) >>>>>>>>> (fd5b27a36b4f09c2191fbf4c23ab61d1) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,710 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (21/25) >>>>>>>>> (3827b667c8e997c9e7e16ad0018cc767) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,720 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (22/25) >>>>>>>>> (4cbe7fa6850e61d695c3ac2a49995e60) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,720 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (23/25) >>>>>>>>> (1450b59a7088dd0ae6c6720d31839167) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,747 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (24/25) >>>>>>>>> (6766fa50924793cec3a4d1234bb62c06) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,748 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (25/25) >>>>>>>>> (2ce8063004c80a4d16104e873f82132e) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,748 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (1/25) (9dee3c4d890f01233d5c95f15a9b3c96) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,748 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (2/25) (fbdd9e6f0a6ab2f5441afa4b171a8db3) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,749 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (3/25) (bbd7f74a8a57288a2e8a5c459418d6b3) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,749 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (4/25) (6b71db98a7a0f2fa53da59f2f8a21cce) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,749 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (5/25) (011b449fae3ff4b9769c7d75b1cc34ef) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,750 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (6/25) (61dec00d3e2736d3178d22f7c5c9e499) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,750 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (7/25) (fa434906c2e64e78743049e21494ad08) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,750 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (8/25) (504a1e8018bd16bbc1cdc5474bc5a496) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,751 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (9/25) (ca432acdde8ac296ee1b7fa169d80260) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,751 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (10/25) >>>>>>>>> (4ec7d078930d8b31e89bc5bf63964029) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,752 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (11/25) >>>>>>>>> (b6d53055b7787e63cda0ccfe6f1cf67d) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,752 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (12/25) >>>>>>>>> (78fc3cd38db931784d45e8b6a0ecd719) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,754 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (13/25) >>>>>>>>> (3d2f2e956e1f5c3518c222f68b37698a) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,755 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (14/25) >>>>>>>>> (c1192e402ab4a018b67f2c74f4286e13) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,755 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (15/25) >>>>>>>>> (4666479516b2ffe3c49ad7c027a80ad3) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,755 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (17/25) >>>>>>>>> (e41bf8f2e7e1034d4aeb993da711994d) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,756 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (18/25) >>>>>>>>> (100bf52dde6379d11399c02e4b2c0a49) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,763 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (19/25) >>>>>>>>> (b74e7a60547032d269422f8ccfe5b40b) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,763 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (20/25) >>>>>>>>> (f8243db3aa35c8cc6e725cff575e5dd1) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,764 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (21/25) >>>>>>>>> (c4666c247ddad9d713670f7a84ab3aca) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,764 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (22/25) >>>>>>>>> (4c3bce50b83ec0e56d3e5940879f8efc) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,764 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (23/25) >>>>>>>>> (00dbd5965e361f476dfabd09ad803e66) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,764 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (24/25) >>>>>>>>> (b0cce659eb47fa75d876f280f53eaa68) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,764 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (25/25) >>>>>>>>> (580c73a4bff8720e996cfdf248b98163) >>>>>>>>> switched from RUNNING to CANCELING >>>>>>>>> 08:59:56,765 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (14/25) >>>>>>>>> (10a5223d3d716bca1a50853f0efcab02) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 08:59:56,766 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (15/25) >>>>>>>>> (4666479516b2ffe3c49ad7c027a80ad3) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 08:59:56,767 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (21/25) >>>>>>>>> (3827b667c8e997c9e7e16ad0018cc767) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 08:59:56,768 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (7/25) (386211d919b02137f42e4df3fefb9619) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 08:59:56,769 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (17/25) >>>>>>>>> (e41bf8f2e7e1034d4aeb993da711994d) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 08:59:56,771 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (14/25) >>>>>>>>> (c1192e402ab4a018b67f2c74f4286e13) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 08:59:56,772 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (25/25) >>>>>>>>> (2ce8063004c80a4d16104e873f82132e) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 08:59:56,773 INFO >>>>>>>>> org.apache.flink.runtime.instance.InstanceManager - >>>>>>>>> Unregistered >>>>>>>>> task manager akka.tcp://flink@10.155.208.138:42222/user/taskmanager. >>>>>>>>> Number >>>>>>>>> of registered task managers 6. Number of available slots 21. >>>>>>>>> 08:59:56,774 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Status of job aeb1eca3a4feefa6fd00b599c0c783d4 (WordCount from >>>>>>>>> SocketTextStream Example) changed to FAILING. >>>>>>>>> java.lang.Exception: The slot in which the task was executed has >>>>>>>>> been released. Probably loss of TaskManager >>>>>>>>> 831a72dad6fbb533b193820f45bdc5bc >>>>>>>>> @ vm-10-155-208-138 - 4 slots - URL: >>>>>>>>> akka.tcp://flink@10.155.208.138:42222/user/taskmanager >>>>>>>>> at >>>>>>>>> org.apache.flink.runtime.instance.SimpleSlot.releaseSlot(SimpleSlot.java:153) >>>>>>>>> at >>>>>>>>> org.apache.flink.runtime.instance.SlotSharingGroupAssignment.releaseSharedSlot(SlotSharingGroupAssignment.java:547) >>>>>>>>> at >>>>>>>>> org.apache.flink.runtime.instance.SharedSlot.releaseSlot(SharedSlot.java:119) >>>>>>>>> at >>>>>>>>> org.apache.flink.runtime.instance.Instance.markDead(Instance.java:156) >>>>>>>>> at >>>>>>>>> org.apache.flink.runtime.instance.InstanceManager.unregisterTaskManager(InstanceManager.java:215) >>>>>>>>> at >>>>>>>>> org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1.applyOrElse(JobManager.scala:696) >>>>>>>>> at >>>>>>>>> scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) >>>>>>>>> at >>>>>>>>> org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:44) >>>>>>>>> at >>>>>>>>> scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) >>>>>>>>> at >>>>>>>>> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33) >>>>>>>>> at >>>>>>>>> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28) >>>>>>>>> at >>>>>>>>> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) >>>>>>>>> at >>>>>>>>> org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28) >>>>>>>>> at akka.actor.Actor$class.aroundReceive(Actor.scala:465) >>>>>>>>> at >>>>>>>>> org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:100) >>>>>>>>> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) >>>>>>>>> at >>>>>>>>> akka.actor.dungeon.DeathWatch$class.receivedTerminated(DeathWatch.scala:46) >>>>>>>>> at >>>>>>>>> akka.actor.ActorCell.receivedTerminated(ActorCell.scala:369) >>>>>>>>> at >>>>>>>>> akka.actor.ActorCell.autoReceiveMessage(ActorCell.scala:501) >>>>>>>>> at akka.actor.ActorCell.invoke(ActorCell.scala:486) >>>>>>>>> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) >>>>>>>>> at akka.dispatch.Mailbox.run(Mailbox.scala:221) >>>>>>>>> at akka.dispatch.Mailbox.exec(Mailbox.scala:231) >>>>>>>>> at >>>>>>>>> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) >>>>>>>>> at >>>>>>>>> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) >>>>>>>>> at >>>>>>>>> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) >>>>>>>>> at >>>>>>>>> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) >>>>>>>>> 08:59:56,791 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (3/25) (bbd7f74a8a57288a2e8a5c459418d6b3) >>>>>>>>> switched from CANCELING to CANCELED >>>>>>>>> 08:59:56,791 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (1/25) (9dee3c4d890f01233d5c95f15a9b3c96) >>>>>>>>> switched from CANCELING to CANCELED >>>>>>>>> 08:59:56,791 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (2/25) (fbdd9e6f0a6ab2f5441afa4b171a8db3) >>>>>>>>> switched from CANCELING to CANCELED >>>>>>>>> 08:59:56,969 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (11/25) >>>>>>>>> (b6d53055b7787e63cda0ccfe6f1cf67d) >>>>>>>>> switched from CANCELING to CANCELED >>>>>>>>> 08:59:56,973 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (12/25) >>>>>>>>> (78fc3cd38db931784d45e8b6a0ecd719) >>>>>>>>> switched from CANCELING to CANCELED >>>>>>>>> 08:59:56,974 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (13/25) >>>>>>>>> (3d2f2e956e1f5c3518c222f68b37698a) >>>>>>>>> switched from CANCELING to CANCELED >>>>>>>>> 08:59:57,117 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (4/25) (6b71db98a7a0f2fa53da59f2f8a21cce) >>>>>>>>> switched from CANCELING to CANCELED >>>>>>>>> 08:59:57,117 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (5/25) (011b449fae3ff4b9769c7d75b1cc34ef) >>>>>>>>> switched from CANCELING to CANCELED >>>>>>>>> 08:59:57,117 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (6/25) (61dec00d3e2736d3178d22f7c5c9e499) >>>>>>>>> switched from CANCELING to CANCELED >>>>>>>>> 09:00:21,690 INFO org.apache.flink.runtime.jobmanager.JobManager >>>>>>>>> - Task manager akka.tcp://flink@10.155.208.136:43058/user/taskmanager >>>>>>>>> terminated. >>>>>>>>> 09:00:21,692 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (8/25) (504a1e8018bd16bbc1cdc5474bc5a496) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 09:00:21,690 WARN akka.remote.RemoteWatcher >>>>>>>>> - Detected unreachable: [akka.tcp://flink@10.155.208.136:43058] >>>>>>>>> 09:00:21,693 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (19/25) >>>>>>>>> (f7fcba6ec0608360f363665afd99fb5d) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 09:00:21,694 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (9/25) (ca432acdde8ac296ee1b7fa169d80260) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 09:00:21,694 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (12/25) >>>>>>>>> (f25aa9d229f5df70aafa40fa59d88264) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 09:00:21,695 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (7/25) (fa434906c2e64e78743049e21494ad08) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 09:00:21,695 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (23/25) >>>>>>>>> (1450b59a7088dd0ae6c6720d31839167) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 09:00:21,696 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - Keyed >>>>>>>>> Aggregation -> Sink: Unnamed (10/25) >>>>>>>>> (4ec7d078930d8b31e89bc5bf63964029) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 09:00:21,696 INFO >>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph - >>>>>>>>> Source: Read >>>>>>>>> Text File Source -> Flat Map (5/25) (0edf387c2b8f7f3e6925192bc7e295ee) >>>>>>>>> switched from CANCELING to FAILED >>>>>>>>> 09:00:21,696 INFO >>>>>>>>> org.apache.flink.runtime.instance.InstanceManager - >>>>>>>>> Unregistered >>>>>>>>> task manager akka.tcp://flink@10.155.208.136:43058/user/taskmanager. >>>>>>>>> Number >>>>>>>>> of registered task managers 5. Number of available slots 17. >>>>>>>>> 09:00:52,689 WARN akka.remote.RemoteWatcher >>>>>>>>> - Detected unreachable: [akka.tcp://flink@10.155.208.135:54516] >>>>> >>>>> ... >>>>> >>>>> [Message clipped] >>>> >>>> >>> >> >
