flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ufuk Celebi <...@apache.org>
Subject Re: OutofMemoryError: Java heap space & Loss of Taskmanager
Date Wed, 16 Mar 2016 17:06:51 GMT
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.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (6/25) (de554cfcbc7f7ecf924fd3bfd1f951ce)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,708 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (7/25) (386211d919b02137f42e4df3fefb9619)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,709 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (11/25) (39e9a6f6c11427bf9024fcf6b88dbd3e)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,709 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (12/25) (f25aa9d229f5df70aafa40fa59d88264)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,709 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (13/25) (1e572ad1eab41b5f219d8ddd3d544699)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,709 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (14/25) (10a5223d3d716bca1a50853f0efcab02)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,709 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (18/25) (498d68b92dbb4c8a2a7a1db344fe01a8)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,709 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (19/25) (f7fcba6ec0608360f363665afd99fb5d)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,710 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (20/25) (fd5b27a36b4f09c2191fbf4c23ab61d1)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,710 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (21/25) (3827b667c8e997c9e7e16ad0018cc767)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,720 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (22/25) (4cbe7fa6850e61d695c3ac2a49995e60)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,720 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (23/25) (1450b59a7088dd0ae6c6720d31839167)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,747 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (24/25) (6766fa50924793cec3a4d1234bb62c06)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,748 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (25/25) (2ce8063004c80a4d16104e873f82132e)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,748 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (1/25) (9dee3c4d890f01233d5c95f15a9b3c96)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,748 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (2/25) (fbdd9e6f0a6ab2f5441afa4b171a8db3)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,749 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (3/25) (bbd7f74a8a57288a2e8a5c459418d6b3)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,749 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (4/25) (6b71db98a7a0f2fa53da59f2f8a21cce)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,749 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (5/25) (011b449fae3ff4b9769c7d75b1cc34ef)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,750 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (6/25) (61dec00d3e2736d3178d22f7c5c9e499)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,750 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (7/25) (fa434906c2e64e78743049e21494ad08)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,750 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (8/25) (504a1e8018bd16bbc1cdc5474bc5a496)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,751 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (9/25) (ca432acdde8ac296ee1b7fa169d80260)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,751 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (10/25) (4ec7d078930d8b31e89bc5bf63964029)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,752 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (11/25) (b6d53055b7787e63cda0ccfe6f1cf67d)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,752 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (12/25) (78fc3cd38db931784d45e8b6a0ecd719)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,754 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (13/25) (3d2f2e956e1f5c3518c222f68b37698a)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,755 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (14/25) (c1192e402ab4a018b67f2c74f4286e13)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,755 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (15/25) (4666479516b2ffe3c49ad7c027a80ad3)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,755 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (17/25) (e41bf8f2e7e1034d4aeb993da711994d)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,756 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (18/25) (100bf52dde6379d11399c02e4b2c0a49)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,763 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (19/25) (b74e7a60547032d269422f8ccfe5b40b)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,763 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (20/25) (f8243db3aa35c8cc6e725cff575e5dd1)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,764 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (21/25) (c4666c247ddad9d713670f7a84ab3aca)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,764 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (22/25) (4c3bce50b83ec0e56d3e5940879f8efc)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,764 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (23/25) (00dbd5965e361f476dfabd09ad803e66)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,764 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (24/25) (b0cce659eb47fa75d876f280f53eaa68)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,764 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (25/25) (580c73a4bff8720e996cfdf248b98163)
>>>>>>>>> switched from RUNNING to CANCELING
>>>>>>>>> 08:59:56,765 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (14/25) (10a5223d3d716bca1a50853f0efcab02)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 08:59:56,766 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (15/25) (4666479516b2ffe3c49ad7c027a80ad3)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 08:59:56,767 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (21/25) (3827b667c8e997c9e7e16ad0018cc767)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 08:59:56,768 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (7/25) (386211d919b02137f42e4df3fefb9619)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 08:59:56,769 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (17/25) (e41bf8f2e7e1034d4aeb993da711994d)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 08:59:56,771 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (14/25) (c1192e402ab4a018b67f2c74f4286e13)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 08:59:56,772 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (25/25) (2ce8063004c80a4d16104e873f82132e)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 08:59:56,773 INFO
>>>>>>>>> org.apache.flink.runtime.instance.InstanceManager             - Unregistered
>>>>>>>>> task manager akka.tcp://flink@10.155.208.138:42222/user/taskmanager. Number
>>>>>>>>> of registered task managers 6. Number of available slots 21.
>>>>>>>>> 08:59:56,774 INFO  org.apache.flink.runtime.jobmanager.JobManager
>>>>>>>>> - Status of job aeb1eca3a4feefa6fd00b599c0c783d4 (WordCount from
>>>>>>>>> SocketTextStream Example) changed to FAILING.
>>>>>>>>> java.lang.Exception: The slot in which the task was executed has
>>>>>>>>> been released. Probably loss of TaskManager 831a72dad6fbb533b193820f45bdc5bc
>>>>>>>>> @ vm-10-155-208-138 - 4 slots - URL:
>>>>>>>>> akka.tcp://flink@10.155.208.138:42222/user/taskmanager
>>>>>>>>>         at
>>>>>>>>> org.apache.flink.runtime.instance.SimpleSlot.releaseSlot(SimpleSlot.java:153)
>>>>>>>>>         at
>>>>>>>>> org.apache.flink.runtime.instance.SlotSharingGroupAssignment.releaseSharedSlot(SlotSharingGroupAssignment.java:547)
>>>>>>>>>         at
>>>>>>>>> org.apache.flink.runtime.instance.SharedSlot.releaseSlot(SharedSlot.java:119)
>>>>>>>>>         at
>>>>>>>>> org.apache.flink.runtime.instance.Instance.markDead(Instance.java:156)
>>>>>>>>>         at
>>>>>>>>> org.apache.flink.runtime.instance.InstanceManager.unregisterTaskManager(InstanceManager.java:215)
>>>>>>>>>         at
>>>>>>>>> org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1.applyOrElse(JobManager.scala:696)
>>>>>>>>>         at
>>>>>>>>> scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
>>>>>>>>>         at
>>>>>>>>> org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:44)
>>>>>>>>>         at
>>>>>>>>> scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
>>>>>>>>>         at
>>>>>>>>> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33)
>>>>>>>>>         at
>>>>>>>>> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28)
>>>>>>>>>         at
>>>>>>>>> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
>>>>>>>>>         at
>>>>>>>>> org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28)
>>>>>>>>>         at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
>>>>>>>>>         at
>>>>>>>>> org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:100)
>>>>>>>>>         at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
>>>>>>>>>         at
>>>>>>>>> akka.actor.dungeon.DeathWatch$class.receivedTerminated(DeathWatch.scala:46)
>>>>>>>>>         at
>>>>>>>>> akka.actor.ActorCell.receivedTerminated(ActorCell.scala:369)
>>>>>>>>>         at
>>>>>>>>> akka.actor.ActorCell.autoReceiveMessage(ActorCell.scala:501)
>>>>>>>>>         at akka.actor.ActorCell.invoke(ActorCell.scala:486)
>>>>>>>>>         at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
>>>>>>>>>         at akka.dispatch.Mailbox.run(Mailbox.scala:221)
>>>>>>>>>         at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
>>>>>>>>>         at
>>>>>>>>> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
>>>>>>>>>         at
>>>>>>>>> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
>>>>>>>>>         at
>>>>>>>>> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>>>>>>>>>         at
>>>>>>>>> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
>>>>>>>>> 08:59:56,791 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (3/25) (bbd7f74a8a57288a2e8a5c459418d6b3)
>>>>>>>>> switched from CANCELING to CANCELED
>>>>>>>>> 08:59:56,791 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (1/25) (9dee3c4d890f01233d5c95f15a9b3c96)
>>>>>>>>> switched from CANCELING to CANCELED
>>>>>>>>> 08:59:56,791 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (2/25) (fbdd9e6f0a6ab2f5441afa4b171a8db3)
>>>>>>>>> switched from CANCELING to CANCELED
>>>>>>>>> 08:59:56,969 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (11/25) (b6d53055b7787e63cda0ccfe6f1cf67d)
>>>>>>>>> switched from CANCELING to CANCELED
>>>>>>>>> 08:59:56,973 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (12/25) (78fc3cd38db931784d45e8b6a0ecd719)
>>>>>>>>> switched from CANCELING to CANCELED
>>>>>>>>> 08:59:56,974 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (13/25) (3d2f2e956e1f5c3518c222f68b37698a)
>>>>>>>>> switched from CANCELING to CANCELED
>>>>>>>>> 08:59:57,117 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (4/25) (6b71db98a7a0f2fa53da59f2f8a21cce)
>>>>>>>>> switched from CANCELING to CANCELED
>>>>>>>>> 08:59:57,117 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (5/25) (011b449fae3ff4b9769c7d75b1cc34ef)
>>>>>>>>> switched from CANCELING to CANCELED
>>>>>>>>> 08:59:57,117 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (6/25) (61dec00d3e2736d3178d22f7c5c9e499)
>>>>>>>>> switched from CANCELING to CANCELED
>>>>>>>>> 09:00:21,690 INFO  org.apache.flink.runtime.jobmanager.JobManager
>>>>>>>>> - Task manager akka.tcp://flink@10.155.208.136:43058/user/taskmanager
>>>>>>>>> terminated.
>>>>>>>>> 09:00:21,692 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (8/25) (504a1e8018bd16bbc1cdc5474bc5a496)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 09:00:21,690 WARN  akka.remote.RemoteWatcher
>>>>>>>>> - Detected unreachable: [akka.tcp://flink@10.155.208.136:43058]
>>>>>>>>> 09:00:21,693 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (19/25) (f7fcba6ec0608360f363665afd99fb5d)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 09:00:21,694 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (9/25) (ca432acdde8ac296ee1b7fa169d80260)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 09:00:21,694 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (12/25) (f25aa9d229f5df70aafa40fa59d88264)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 09:00:21,695 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (7/25) (fa434906c2e64e78743049e21494ad08)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 09:00:21,695 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (23/25) (1450b59a7088dd0ae6c6720d31839167)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 09:00:21,696 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Keyed
>>>>>>>>> Aggregation -> Sink: Unnamed (10/25) (4ec7d078930d8b31e89bc5bf63964029)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 09:00:21,696 INFO
>>>>>>>>> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Read
>>>>>>>>> Text File Source -> Flat Map (5/25) (0edf387c2b8f7f3e6925192bc7e295ee)
>>>>>>>>> switched from CANCELING to FAILED
>>>>>>>>> 09:00:21,696 INFO
>>>>>>>>> org.apache.flink.runtime.instance.InstanceManager             - Unregistered
>>>>>>>>> task manager akka.tcp://flink@10.155.208.136:43058/user/taskmanager. Number
>>>>>>>>> of registered task managers 5. Number of available slots 17.
>>>>>>>>> 09:00:52,689 WARN  akka.remote.RemoteWatcher
>>>>>>>>> - Detected unreachable: [akka.tcp://flink@10.155.208.135:54516]
>>>>>
>>>>> ...
>>>>>
>>>>> [Message clipped]
>>>>
>>>>
>>>
>>
>

Mime
View raw message