flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ravinder Kaur <neetu0...@gmail.com>
Subject Re: OutofMemoryError: Java heap space & Loss of Taskmanager
Date Wed, 16 Mar 2016 17:11:26 GMT
Hello Ufuk,

These issues occur while running streaming programs.

Kind Regards,
Ravinder Kaur
On Mar 16, 2016 6:07 PM, "Ufuk Celebi" <uce@apache.org> wrote:

> Are you facing these issues with the batch or streaming programs?
>
> – Ufuk
>
> On Wed, Mar 16, 2016 at 4:30 PM, Till Rohrmann <trohrmann@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 <neetu0404@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 <neetu0404@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 <neetu0404@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 <neetu0404@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 <trohrmann@apache.org
> >
> >>>>> wrote:
> >>>>>>
> >>>>>> Have you checked the logs?
> >>>>>>
> >>>>>> Cheers,
> >>>>>> Till
> >>>>>>
> >>>>>> On Tue, Mar 15, 2016 at 4:42 PM, Ravinder Kaur <neetu0404@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 <
> neetu0404@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
> >>>>>>>> <neetu0404@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.exec...

Mime
View raw message