flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ravinder Kaur <neetu0...@gmail.com>
Subject Re: OutofMemoryError: Java heap space & Loss of Taskmanager
Date Tue, 15 Mar 2016 22:20:04 GMT
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