14:32:12,856 INFO org.apache.flink.runtime.jobmanager.JobManager - ------------------------------------------------------- 14:32:12,857 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager (Version: 0.6-incubating, Rev:053f4c6, Date:15.08.2014 @ 13:57:49 CEST) 14:32:12,858 INFO org.apache.flink.runtime.jobmanager.JobManager - Current user: hoenicke 14:32:12,858 INFO org.apache.flink.runtime.jobmanager.JobManager - JVM: Java HotSpot(TM) 64-Bit Server VM - Sun Microsystems Inc. - 1.0/20.14-b 01 14:32:12,858 INFO org.apache.flink.runtime.jobmanager.JobManager - Startup Options: -XX:+UseConcMarkSweepGC -XX:+CMSClassUnloadingEnabled -XX:M axPermSize=256m -Xms20000m -Xmx20000m 14:32:12,858 INFO org.apache.flink.runtime.jobmanager.JobManager - Maximum heap size: 19962 MiBytes 14:32:12,858 INFO org.apache.flink.runtime.jobmanager.JobManager - JAVA_HOME: /usr/lib/jvm/jdk1.6.0_41 14:32:12,858 INFO org.apache.flink.runtime.jobmanager.JobManager - ------------------------------------------------------- 14:32:12,913 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting job manager in CLUSTER mode 14:32:12,916 INFO org.apache.flink.runtime.jobmanager.JobManager - Trying to load org.apache.flink.runtime.instance.DefaultInstanceManager as in stance manager 14:32:12,922 INFO org.apache.flink.runtime.jobmanager.JobManager - Trying to load org.apache.flink.runtime.jobmanager.scheduler.DefaultScheduler as scheduler 14:32:12,933 INFO org.apache.flink.runtime.jobmanager.web.WebInfoServer - Setting up web info server, using web-root directory '/home/hoenicke/flink-0. 6-incubating/bin/../conf/.././resources/web-docs-infoserver'. 14:32:12,933 INFO org.apache.flink.runtime.jobmanager.web.WebInfoServer - Web info server will display information about nephele job-manager on dbis41, port 8081. 14:32:13,028 INFO org.apache.flink.runtime.jobmanager.web.WebInfoServer - Starting web info server for JobManager on port 8081 14:32:23,172 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - Creating instance for dbis42 (ipcPort=37589, dataPort=53066), parent is root 14:32:23,174 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - New number of registered hosts is 1 14:32:23,881 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - Creating instance for dbis43 (ipcPort=55584, dataPort=60512), parent is root 14:32:23,881 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - New number of registered hosts is 2 14:32:24,355 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - Creating instance for dbis44 (ipcPort=52319, dataPort=38155), parent is root 14:32:24,355 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - New number of registered hosts is 3 14:32:26,066 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - Creating instance for dbis51 (ipcPort=47708, dataPort=36810), parent is root 14:32:26,067 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - New number of registered hosts is 4 14:32:26,470 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - Creating instance for dbis52 (ipcPort=54052, dataPort=50177), parent is root 14:32:26,470 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - New number of registered hosts is 5 14:32:27,334 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - Creating instance for dbis53 (ipcPort=40244, dataPort=36692), parent is root 14:32:27,334 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - New number of registered hosts is 6 14:32:27,692 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - Creating instance for dbis54 (ipcPort=35437, dataPort=59613), parent is root 14:32:27,692 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - New number of registered hosts is 7 14:32:27,880 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - Creating instance for dbis61 (ipcPort=55971, dataPort=41778), parent is root 14:32:27,880 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - New number of registered hosts is 8 14:32:28,714 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - Creating instance for dbis62 (ipcPort=48523, dataPort=52932), parent is root 14:32:28,714 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - New number of registered hosts is 9 14:32:29,304 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - Creating instance for dbis63 (ipcPort=49848, dataPort=54262), parent is root 14:32:29,304 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - New number of registered hosts is 10 14:32:30,432 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - Creating instance for dbis64 (ipcPort=39772, dataPort=38106), parent is root 14:32:30,433 INFO org.apache.flink.runtime.instance.DefaultInstanceManager - New number of registered hosts is 11 14:32:59,330 INFO org.apache.flink.runtime.jobmanager.JobManager - Creating initial execution graph from job graph WordCount Example 14:32:59,390 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job input vertex CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink -0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere. version6.MassJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) generated 11 i nput splits 14:32:59,397 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job input vertex DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-i ncubating/input/inputNummeriert.txt) - UTF-8) generated 11 input splits 14:32:59,462 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - Trying to load input split assigner for type org.apache.flink.core.fs. FileInputSplit 14:32:59,464 INFO org.apache.flink.runtime.jobmanager.JobManager - Scheduling job WordCount Example 14:32:59,470 INFO org.apache.flink.runtime.jobmanager.scheduler.DefaultSchedule r - Requesting 11 slots for job 0c24a6d2539640005ccbb5b34adb6400 14:32:59,473 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (1/11) 14:32:59,500 INFO org.apache.flink.runtime.jobmanager.JobManager - Status of job WordCount Example(0c24a6d2539640005ccbb5b34adb6400) changed to SCHEDULED 14:32:59,500 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Reduce (SUM(1)) (1/ 11) 14:32:59,500 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task GroupReduce (eu.str atosphere.version6.MassJoinOriginJob$ReduceGroupTokenOrdering) (1/1) 14:32:59,500 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (1/11) 14:32:59,500 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (1/11) 14:32:59,501 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (1/11) 14:32:59,501 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (1/11) 14:32:59,501 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (1/11) 14:32:59,501 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (1/11) 14:32:59,501 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (2/11) 14:32:59,501 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (2/11) 14:32:59,501 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (3/11) 14:32:59,501 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (3/11) 14:32:59,502 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (4/11) 14:32:59,502 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (4/11) 14:32:59,502 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (5/11) 14:32:59,502 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (5/11) 14:32:59,502 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (6/11) 14:32:59,502 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (6/11) 14:32:59,502 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (7/11) 14:32:59,502 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (7/11) 14:32:59,502 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (8/11) 14:32:59,502 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (8/11) 14:32:59,503 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (9/11) 14:32:59,503 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (9/11) 14:32:59,503 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (10/11) 14:32:59,503 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (10/11) 14:32:59,503 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (11/11) 14:32:59,503 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (11/11) 14:32:59,503 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (2/11) 14:32:59,503 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (3/11) 14:32:59,503 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (4/11) 14:32:59,504 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (5/11) 14:32:59,504 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (6/11) 14:32:59,504 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (7/11) 14:32:59,504 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (8/11) 14:32:59,504 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (9/11) 14:32:59,504 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (10/11) 14:32:59,504 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (11/11) 14:32:59,504 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (2/11) 14:32:59,505 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (3/11) 14:32:59,505 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (4/11) 14:32:59,505 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (5/11) 14:32:59,505 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (6/11) 14:32:59,505 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (7/11) 14:32:59,505 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (8/11) 14:32:59,505 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (9/11) 14:32:59,505 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (10/11) 14:32:59,506 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (11/11) 14:32:59,506 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (1/11) 14:32:59,506 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (2/11) 14:32:59,506 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (2/11) 14:32:59,506 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (2/11) 14:32:59,506 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (3/11) 14:32:59,506 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (3/11) 14:32:59,506 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (3/11) 14:32:59,506 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (4/11) 14:32:59,507 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (4/11) 14:32:59,507 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (4/11) 14:32:59,507 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (5/11) 14:32:59,507 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (5/11) 14:32:59,507 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (5/11) 14:32:59,507 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (6/11) 14:32:59,507 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (6/11) 14:32:59,507 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (6/11) 14:32:59,508 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (7/11) 14:32:59,508 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (7/11) 14:32:59,508 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (7/11) 14:32:59,508 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (8/11) 14:32:59,508 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (8/11) 14:32:59,508 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (8/11) 14:32:59,508 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (9/11) 14:32:59,508 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (9/11) 14:32:59,509 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (9/11) 14:32:59,509 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (10/11) 14:32:59,509 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (10/11) 14:32:59,509 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (10/11) 14:32:59,509 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (11/11) 14:32:59,509 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (11/11) 14:32:59,509 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (11/11) 14:32:59,510 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Reduce (SUM(1)) (2/ 11) 14:32:59,510 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Reduce (SUM(1)) (3/ 11) 14:32:59,510 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Reduce (SUM(1)) (4/ 11) 14:32:59,510 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Reduce (SUM(1)) (5/ 11) 14:32:59,510 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Reduce (SUM(1)) (6/ 11) 14:32:59,510 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Reduce (SUM(1)) (7/ 11) 14:32:59,510 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Reduce (SUM(1)) (8/ 11) 14:32:59,510 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Reduce (SUM(1)) (9/ 11) 14:32:59,510 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Reduce (SUM(1)) (10 /11) 14:32:59,510 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task Reduce (SUM(1)) (11 /11) 14:32:59,511 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (2/11) 14:32:59,511 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (3/11) 14:32:59,511 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (4/11) 14:32:59,511 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (5/11) 14:32:59,511 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (6/11) 14:32:59,511 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (7/11) 14:32:59,512 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (8/11) 14:32:59,512 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (9/11) 14:32:59,512 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (10/11) 14:32:59,512 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (11/11) 14:32:59,512 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (1/11) 14:32:59,513 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (2/11) 14:32:59,513 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (3/11) 14:32:59,513 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (4/11) 14:32:59,513 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (5/11) 14:32:59,513 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (6/11) 14:32:59,513 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (7/11) 14:32:59,513 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (8/11) 14:32:59,513 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (9/11) 14:32:59,514 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (10/11) 14:32:59,514 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from CREATED to SCHEDULED for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (11/11) 14:32:59,515 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task GroupReduce (eu.st ratosphere.version6.MassJoinOriginJob$ReduceGroupTokenOrdering) (1/1) 14:32:59,515 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (1/11) 14:32:59,515 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (1/11) 14:32:59,515 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Reduce (SUM(1)) (1 /11) 14:32:59,516 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (1/11) 14:32:59,516 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (1/11) 14:32:59,516 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (1/11) 14:32:59,516 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (1/11) 14:32:59,516 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (1/11) 14:32:59,516 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (1/11) 14:32:59,516 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (1/11) 14:32:59,516 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (2/11) 14:32:59,517 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (2/11) 14:32:59,517 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (2/11) 14:32:59,517 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (2/11) 14:32:59,517 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (2/11) 14:32:59,517 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Reduce (SUM(1)) (2 /11) 14:32:59,517 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (2/11) 14:32:59,517 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (2/11) 14:32:59,518 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (2/11) 14:32:59,518 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (2/11) 14:32:59,518 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (3/11) 14:32:59,519 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (3/11) 14:32:59,519 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (3/11) 14:32:59,519 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Reduce (SUM(1)) (3 /11) 14:32:59,519 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (3/11) 14:32:59,520 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (3/11) 14:32:59,520 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (3/11) 14:32:59,520 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (3/11) 14:32:59,521 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (3/11) 14:32:59,521 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (3/11) 14:32:59,521 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (4/11) 14:32:59,521 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (4/11) 14:32:59,521 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (4/11) 14:32:59,522 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Reduce (SUM(1)) (4 /11) 14:32:59,522 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (4/11) 14:32:59,522 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (4/11) 14:32:59,522 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (4/11) 14:32:59,523 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (4/11) 14:32:59,523 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (4/11) 14:32:59,524 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (4/11) 14:32:59,524 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (5/11) 14:32:59,524 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (5/11) 14:32:59,524 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (5/11) 14:32:59,524 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (5/11) 14:32:59,525 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Reduce (SUM(1)) (5 /11) 14:32:59,525 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (5/11) 14:32:59,525 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (5/11) 14:32:59,525 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (5/11) 14:32:59,525 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (5/11) 14:32:59,525 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (5/11) 14:32:59,526 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (6/11) 14:32:59,526 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (6/11) 14:32:59,526 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (6/11) 14:32:59,526 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (6/11) 14:32:59,526 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (6/11) 14:32:59,526 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (6/11) 14:32:59,526 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (6/11) 14:32:59,526 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Reduce (SUM(1)) (6 /11) 14:32:59,527 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (6/11) 14:32:59,527 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (6/11) 14:32:59,527 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Reduce (SUM(1)) (7 /11) 14:32:59,527 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (7/11) 14:32:59,527 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (7/11) 14:32:59,527 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (7/11) 14:32:59,527 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (7/11) 14:32:59,527 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (7/11) 14:32:59,528 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (7/11) 14:32:59,528 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (7/11) 14:32:59,528 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (7/11) 14:32:59,528 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (7/11) 14:32:59,528 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (8/11) 14:32:59,528 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Reduce (SUM(1)) (8 /11) 14:32:59,528 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (8/11) 14:32:59,528 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (8/11) 14:32:59,529 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (8/11) 14:32:59,529 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (8/11) 14:32:59,529 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (8/11) 14:32:59,529 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (8/11) 14:32:59,529 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (8/11) 14:32:59,529 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (8/11) 14:32:59,529 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (9/11) 14:32:59,529 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (9/11) 14:32:59,530 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (9/11) 14:32:59,530 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (9/11) 14:32:59,530 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (9/11) 14:32:59,530 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (9/11) 14:32:59,530 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Reduce (SUM(1)) (9 /11) 14:32:59,530 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (9/11) 14:32:59,530 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (9/11) 14:32:59,530 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (9/11) 14:32:59,530 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (10/11) 14:32:59,531 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (10/11) 14:32:59,531 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (10/11) 14:32:59,531 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Reduce (SUM(1)) (1 0/11) 14:32:59,531 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (10/11) 14:32:59,531 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (10/11) 14:32:59,531 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (10/11) 14:32:59,531 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (10/11) 14:32:59,531 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (10/11) 14:32:59,532 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (10/11) 14:32:59,532 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (11/11) 14:32:59,532 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (11/11) 14:32:59,532 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (11/11) 14:32:59,532 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (11/11) 14:32:59,532 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (11/11) 14:32:59,532 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (11/11) 14:32:59,532 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task Reduce (SUM(1)) (1 1/11) 14:32:59,533 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (11/11) 14:32:59,533 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (11/11) 14:32:59,533 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from SCHEDULED to ASSIGNED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (11/11) 14:32:59,533 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (1/11) 14:32:59,534 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (2/11) 14:32:59,534 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (3/11) 14:32:59,534 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (4/11) 14:32:59,534 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (5/11) 14:32:59,534 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (6/11) 14:32:59,534 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (7/11) 14:32:59,534 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (8/11) 14:32:59,534 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (9/11) 14:32:59,534 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (10/11) 14:32:59,534 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (11/11) 14:32:59,535 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (1/11) 14:32:59,535 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (2/11) 14:32:59,535 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (3/11) 14:32:59,535 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (4/11) 14:32:59,535 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (5/11) 14:32:59,535 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (6/11) 14:32:59,535 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (7/11) 14:32:59,535 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (8/11) 14:32:59,535 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (9/11) 14:32:59,535 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (10/11) 14:32:59,535 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (11/11) 14:32:59,536 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (1/11) 14:32:59,536 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (1/11) 14:32:59,536 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (2/11) 14:32:59,537 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (2/11) 14:32:59,537 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (3/11) 14:32:59,537 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (3/11) 14:32:59,538 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (4/11) 14:32:59,538 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (4/11) 14:32:59,539 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (5/11) 14:32:59,539 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (5/11) 14:32:59,540 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (7/11) 14:32:59,540 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (7/11) 14:32:59,540 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (6/11) 14:32:59,540 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (6/11) 14:32:59,541 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (8/11) 14:32:59,542 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (8/11) 14:32:59,543 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (9/11) 14:32:59,543 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (9/11) 14:32:59,544 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (10/11) 14:32:59,544 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (10/11) 14:32:59,545 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CHAIN DataSource (Text InputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequenc ies) -> Combine(SUM(1)) (11/11) 14:32:59,545 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSource (TextInputF ormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF -8) (11/11) 14:32:59,587 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0. 6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.ver sion6.MassJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (11/11) on dbis43 (ipcPort=55584, dataPort=60512) 14:32:59,588 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incu bating/input/inputNummeriert.txt) - UTF-8) (11/11) on dbis43 (ipcPort=55584, dat aPort=60512) 14:32:59,588 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0. 6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.ver sion6.MassJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (10/11) on dbis42 (ipcPort=37589, dataPort=53066) 14:32:59,588 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incu bating/input/inputNummeriert.txt) - UTF-8) (10/11) on dbis42 (ipcPort=37589, dat aPort=53066) 14:32:59,590 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0. 6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.ver sion6.MassJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (5/11) on dbis51 (ipcPort=47708, dataPort=36810) 14:32:59,591 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incu bating/input/inputNummeriert.txt) - UTF-8) (5/11) on dbis51 (ipcPort=47708, data Port=36810) 14:32:59,603 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0. 6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.ver sion6.MassJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (2/11) on dbis52 (ipcPort=54052, dataPort=50177) 14:32:59,604 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incu bating/input/inputNummeriert.txt) - UTF-8) (2/11) on dbis52 (ipcPort=54052, data Port=50177) 14:32:59,606 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0. 6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.ver sion6.MassJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (8/11) on dbis63 (ipcPort=49848, dataPort=54262) 14:32:59,607 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incu bating/input/inputNummeriert.txt) - UTF-8) (8/11) on dbis63 (ipcPort=49848, data Port=54262) 14:32:59,614 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0. 6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.ver sion6.MassJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (6/11) on dbis61 (ipcPort=55971, dataPort=41778) 14:32:59,614 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incu bating/input/inputNummeriert.txt) - UTF-8) (6/11) on dbis61 (ipcPort=55971, data Port=41778) 14:32:59,616 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0. 6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.ver sion6.MassJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (9/11) on dbis62 (ipcPort=48523, dataPort=52932) 14:32:59,616 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incu bating/input/inputNummeriert.txt) - UTF-8) (9/11) on dbis62 (ipcPort=48523, data Port=52932) 14:32:59,617 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0. 6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.ver sion6.MassJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (4/11) on dbis54 (ipcPort=35437, dataPort=59613) 14:32:59,617 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incu bating/input/inputNummeriert.txt) - UTF-8) (4/11) on dbis54 (ipcPort=35437, data Port=59613) 14:32:59,619 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0. 6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.ver sion6.MassJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (3/11) on dbis64 (ipcPort=39772, dataPort=38106) 14:32:59,619 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incu bating/input/inputNummeriert.txt) - UTF-8) (3/11) on dbis64 (ipcPort=39772, data Port=38106) 14:32:59,620 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0. 6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.ver sion6.MassJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (1/11) on dbis53 (ipcPort=40244, dataPort=36692) 14:32:59,620 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incu bating/input/inputNummeriert.txt) - UTF-8) (1/11) on dbis53 (ipcPort=40244, data Port=36692) 14:32:59,632 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0. 6-incubating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.ver sion6.MassJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (7/11) on dbis44 (ipcPort=52319, dataPort=38155) 14:32:59,632 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incu bating/input/inputNummeriert.txt) - UTF-8) (7/11) on dbis44 (ipcPort=52319, data Port=38155) 14:32:59,820 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CHAIN DataSource (Te xtInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.tx t) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreque ncies) -> Combine(SUM(1)) (11/11) 14:32:59,821 INFO org.apache.flink.runtime.jobmanager.JobManager - Status of job WordCount Example(0c24a6d2539640005ccbb5b34adb6400) changed to RUNNING 14:32:59,826 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSource (TextInpu tFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - U TF-8) (5/11) 14:32:59,836 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis51 (ipcPort=47708, dataPort=36810) receives remote file inpu t split (distance 2147483647) 14:32:59,836 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/ input/inputNummeriert.txt) - UTF-8) (5/11) receives input split 6 14:32:59,846 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CHAIN DataSource (Te xtInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.tx t) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreque ncies) -> Combine(SUM(1)) (9/11) 14:32:59,848 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSource (TextInpu tFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - U TF-8) (9/11) 14:32:59,849 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CHAIN DataSource (Te xtInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.tx t) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreque ncies) -> Combine(SUM(1)) (10/11) 14:32:59,850 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSource (TextInpu tFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - U TF-8) (10/11) 14:32:59,852 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis62 (ipcPort=48523, dataPort=52932) receives remote file inpu t split (distance 2147483647) 14:32:59,853 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/ input/inputNummeriert.txt) - UTF-8) (9/11) receives input split 2 14:32:59,853 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CHAIN DataSource (Te xtInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.tx t) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreque ncies) -> Combine(SUM(1)) (7/11) 14:32:59,855 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis42 (ipcPort=37589, dataPort=53066) receives remote file inpu t split (distance 2147483647) 14:32:59,855 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/ input/inputNummeriert.txt) - UTF-8) (10/11) receives input split 9 14:32:59,856 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSource (TextInpu tFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - U TF-8) (7/11) 14:32:59,857 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CHAIN DataSource (Te xtInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.tx t) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreque ncies) -> Combine(SUM(1)) (5/11) 14:32:59,859 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSource (TextInpu tFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - U TF-8) (11/11) 14:32:59,860 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis44 (ipcPort=52319, dataPort=38155) receives remote file inpu t split (distance 2147483647) 14:32:59,860 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/ input/inputNummeriert.txt) - UTF-8) (7/11) receives input split 10 14:32:59,863 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis43 (ipcPort=55584, dataPort=60512) receives remote file inpu t split (distance 2147483647) 14:32:59,863 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/ input/inputNummeriert.txt) - UTF-8) (11/11) receives input split 5 14:32:59,864 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CHAIN DataSource (Te xtInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.tx t) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreque ncies) -> Combine(SUM(1)) (4/11) 14:32:59,865 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CHAIN DataSource (Te xtInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.tx t) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreque ncies) -> Combine(SUM(1)) (6/11) 14:32:59,866 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSource (TextInpu tFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - U TF-8) (4/11) 14:32:59,867 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSource (TextInpu tFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - U TF-8) (6/11) 14:32:59,868 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis54 (ipcPort=35437, dataPort=59613) receives remote file inpu t split (distance 2147483647) 14:32:59,868 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/ input/inputNummeriert.txt) - UTF-8) (4/11) receives input split 1 14:32:59,870 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis61 (ipcPort=55971, dataPort=41778) receives remote file inpu t split (distance 2147483647) 14:32:59,870 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/ input/inputNummeriert.txt) - UTF-8) (6/11) receives input split 7 14:32:59,876 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CHAIN DataSource (Te xtInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.tx t) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreque ncies) -> Combine(SUM(1)) (3/11) 14:32:59,881 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (9/11) 14:32:59,881 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (9/11) 14:32:59,884 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Map (eu.stratosphere.version6.MassJoinOriginJob$SplitNMapper) ( 9/11) on dbis62 (ipcPort=48523, dataPort=52932) 14:32:59,885 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (10/11) 14:32:59,885 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (10/11) 14:32:59,886 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (7/11) 14:32:59,886 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (7/11) 14:32:59,888 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Map (eu.stratosphere.version6.MassJoinOriginJob$SplitNMapper) ( 10/11) on dbis42 (ipcPort=37589, dataPort=53066) 14:32:59,890 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Map (eu.stratosphere.version6.MassJoinOriginJob$SplitNMapper) ( 7/11) on dbis44 (ipcPort=52319, dataPort=38155) 14:32:59,894 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (5/11) 14:32:59,895 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (5/11) 14:32:59,897 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Map (eu.stratosphere.version6.MassJoinOriginJob$SplitNMapper) ( 5/11) on dbis51 (ipcPort=47708, dataPort=36810) 14:32:59,902 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CHAIN DataSource (Te xtInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.tx t) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreque ncies) -> Combine(SUM(1)) (8/11) 14:32:59,903 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSource (TextInpu tFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - U TF-8) (8/11) 14:32:59,904 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis43 (ipcPort=55584, dataPort=60512) receives remote file inpu t split (distance 2147483647) 14:32:59,904 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incub ating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.M assJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (11/11) receives input s plit 9 14:32:59,906 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis63 (ipcPort=49848, dataPort=54262) receives remote file inpu t split (distance 2147483647) 14:32:59,907 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/ input/inputNummeriert.txt) - UTF-8) (8/11) receives input split 3 14:32:59,907 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSource (TextInpu tFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - U TF-8) (3/11) 14:32:59,908 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CHAIN DataSource (Te xtInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.tx t) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreque ncies) -> Combine(SUM(1)) (2/11) 14:32:59,910 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSource (TextInpu tFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - U TF-8) (2/11) 14:32:59,910 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Map (eu.stratosphere .version6.MassJoinOriginJob$SplitNMapper) (9/11) 14:32:59,911 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis64 (ipcPort=39772, dataPort=38106) receives remote file inpu t split (distance 2147483647) 14:32:59,911 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/ input/inputNummeriert.txt) - UTF-8) (3/11) receives input split 8 14:32:59,913 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis52 (ipcPort=54052, dataPort=50177) receives remote file inpu t split (distance 2147483647) 14:32:59,913 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/ input/inputNummeriert.txt) - UTF-8) (2/11) receives input split 0 14:32:59,915 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Map (eu.stratosphere .version6.MassJoinOriginJob$SplitNMapper) (7/11) 14:32:59,916 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Map (eu.stratosphere .version6.MassJoinOriginJob$SplitNMapper) (10/11) 14:32:59,917 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (4/11) 14:32:59,918 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (4/11) 14:32:59,920 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Map (eu.stratosphere.version6.MassJoinOriginJob$SplitNMapper) ( 4/11) on dbis54 (ipcPort=35437, dataPort=59613) 14:32:59,921 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis42 (ipcPort=37589, dataPort=53066) receives remote file inpu t split (distance 2147483647) 14:32:59,921 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incub ating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.M assJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (10/11) receives input s plit 1 14:32:59,923 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (11/11) 14:32:59,923 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (11/11) 14:32:59,925 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis62 (ipcPort=48523, dataPort=52932) receives remote file inpu t split (distance 2147483647) 14:32:59,925 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incub ating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.M assJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (9/11) receives input sp lit 5 14:32:59,926 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CHAIN DataSource (Te xtInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.tx t) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreque ncies) -> Combine(SUM(1)) (1/11) 14:32:59,927 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Map (eu.stratosphere.version6.MassJoinOriginJob$SplitNMapper) ( 11/11) on dbis43 (ipcPort=55584, dataPort=60512) 14:32:59,927 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis44 (ipcPort=52319, dataPort=38155) receives remote file inpu t split (distance 2147483647) 14:32:59,927 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incub ating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.M assJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (7/11) receives input sp lit 3 14:32:59,927 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSource (TextInpu tFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - U TF-8) (1/11) 14:32:59,930 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis51 (ipcPort=47708, dataPort=36810) receives remote file inpu t split (distance 2147483647) 14:32:59,930 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incub ating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.M assJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (5/11) receives input sp lit 10 14:32:59,933 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis53 (ipcPort=40244, dataPort=36692) receives remote file inpu t split (distance 2147483647) 14:32:59,933 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/ input/inputNummeriert.txt) - UTF-8) (1/11) receives input split 4 14:32:59,936 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis54 (ipcPort=35437, dataPort=59613) receives remote file inpu t split (distance 2147483647) 14:32:59,936 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incub ating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.M assJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (4/11) receives input sp lit 6 14:32:59,943 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis61 (ipcPort=55971, dataPort=41778) receives remote file inpu t split (distance 2147483647) 14:32:59,943 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incub ating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.M assJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (6/11) receives input sp lit 0 14:32:59,959 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (6/11) 14:32:59,959 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (6/11) 14:32:59,962 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Map (eu.stratosphere.version6.MassJoinOriginJob$SplitNMapper) ( 6/11) on dbis61 (ipcPort=55971, dataPort=41778) 14:32:59,965 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (8/11) 14:32:59,965 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (8/11) 14:32:59,966 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Map (eu.stratosphere .version6.MassJoinOriginJob$SplitNMapper) (5/11) 14:32:59,968 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Map (eu.stratosphere.version6.MassJoinOriginJob$SplitNMapper) ( 8/11) on dbis63 (ipcPort=49848, dataPort=54262) 14:32:59,972 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Map (eu.stratosphere .version6.MassJoinOriginJob$SplitNMapper) (4/11) 14:32:59,989 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis63 (ipcPort=49848, dataPort=54262) receives remote file inpu t split (distance 2147483647) 14:32:59,989 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incub ating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.M assJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (8/11) receives input sp lit 7 14:32:59,990 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Map (eu.stratosphere .version6.MassJoinOriginJob$SplitNMapper) (11/11) 14:32:59,993 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis64 (ipcPort=39772, dataPort=38106) receives remote file inpu t split (distance 2147483647) 14:32:59,993 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incub ating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.M assJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (3/11) receives input sp lit 8 14:32:59,994 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (3/11) 14:32:59,995 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (3/11) 14:32:59,995 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis52 (ipcPort=54052, dataPort=50177) receives remote file inpu t split (distance 2147483647) 14:32:59,995 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incub ating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.M assJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (2/11) receives input sp lit 4 14:32:59,997 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (2/11) 14:32:59,997 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (2/11) 14:32:59,998 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Map (eu.stratosphere.version6.MassJoinOriginJob$SplitNMapper) ( 3/11) on dbis64 (ipcPort=39772, dataPort=38106) 14:32:59,999 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (1/11) 14:32:59,999 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Map (eu.stratosphere.v ersion6.MassJoinOriginJob$SplitNMapper) (1/11) 14:33:00,000 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Map (eu.stratosphere.version6.MassJoinOriginJob$SplitNMapper) ( 2/11) on dbis52 (ipcPort=54052, dataPort=50177) 14:33:00,002 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Map (eu.stratosphere.version6.MassJoinOriginJob$SplitNMapper) ( 1/11) on dbis53 (ipcPort=40244, dataPort=36692) 14:33:00,016 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Map (eu.stratosphere .version6.MassJoinOriginJob$SplitNMapper) (6/11) 14:33:00,016 INFO org.apache.flink.runtime.jobmanager.splitassigner.file.FileIn putSplitList - dbis53 (ipcPort=40244, dataPort=36692) receives remote file inpu t split (distance 2147483647) 14:33:00,017 INFO org.apache.flink.runtime.jobmanager.splitassigner.InputSplitM anager - CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incub ating/input/inputNummeriert.txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.M assJoinOriginJob$FlatMapFrequencies) -> Combine(SUM(1)) (1/11) receives input sp lit 2 14:33:00,034 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Map (eu.stratosphere .version6.MassJoinOriginJob$SplitNMapper) (8/11) 14:33:00,062 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Map (eu.stratosphere .version6.MassJoinOriginJob$SplitNMapper) (1/11) 14:33:00,070 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Map (eu.stratosphere .version6.MassJoinOriginJob$SplitNMapper) (3/11) 14:33:00,083 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Map (eu.stratosphere .version6.MassJoinOriginJob$SplitNMapper) (2/11) 14:33:08,746 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Reduce (SUM(1)) (1/11) 14:33:08,747 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Reduce (SUM(1)) (1/11) 14:33:09,050 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Reduce (SUM(1)) (1/11) on dbis53 (ipcPort=40244, dataPort=36692 ) 14:33:09,060 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Reduce (SUM(1)) (1/1 1) 14:33:09,210 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Reduce (SUM(1)) (2/11) 14:33:09,210 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Reduce (SUM(1)) (2/11) 14:33:09,214 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Reduce (SUM(1)) (2/11) on dbis52 (ipcPort=54052, dataPort=50177 ) 14:33:09,938 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Reduce (SUM(1)) (2/1 1) 14:33:09,991 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Reduce (SUM(1)) (3/11) 14:33:09,991 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Reduce (SUM(1)) (3/11) 14:33:09,996 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Reduce (SUM(1)) (3/11) on dbis64 (ipcPort=39772, dataPort=38106 ) 14:33:10,006 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Reduce (SUM(1)) (3/1 1) 14:33:10,026 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Reduce (SUM(1)) (4/11) 14:33:10,026 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Reduce (SUM(1)) (4/11) 14:33:10,031 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Reduce (SUM(1)) (4/11) on dbis54 (ipcPort=35437, dataPort=59613 ) 14:33:10,041 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Reduce (SUM(1)) (4/1 1) 14:33:10,124 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Reduce (SUM(1)) (5/11) 14:33:10,124 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Reduce (SUM(1)) (5/11) 14:33:10,128 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Reduce (SUM(1)) (5/11) on dbis51 (ipcPort=47708, dataPort=36810 ) 14:33:10,151 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Reduce (SUM(1)) (5/1 1) 14:33:10,153 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Reduce (SUM(1)) (6/11) 14:33:10,153 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Reduce (SUM(1)) (6/11) 14:33:10,157 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Reduce (SUM(1)) (6/11) on dbis61 (ipcPort=55971, dataPort=41778 ) 14:33:10,164 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Reduce (SUM(1)) (6/1 1) 14:33:10,258 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Reduce (SUM(1)) (7/11) 14:33:10,259 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Reduce (SUM(1)) (7/11) 14:33:10,263 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Reduce (SUM(1)) (7/11) on dbis44 (ipcPort=52319, dataPort=38155 ) 14:33:10,275 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Reduce (SUM(1)) (7/1 1) 14:33:10,319 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Reduce (SUM(1)) (8/11) 14:33:10,319 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Reduce (SUM(1)) (8/11) 14:33:10,324 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Reduce (SUM(1)) (8/11) on dbis63 (ipcPort=49848, dataPort=54262 ) 14:33:10,356 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Reduce (SUM(1)) (8/1 1) 14:33:10,369 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Reduce (SUM(1)) (9/11) 14:33:10,369 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Reduce (SUM(1)) (9/11) 14:33:10,395 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Reduce (SUM(1)) (9/11) on dbis62 (ipcPort=48523, dataPort=52932 ) 14:33:10,410 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Reduce (SUM(1)) (9/1 1) 14:33:10,449 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Reduce (SUM(1)) (10/11 ) 14:33:10,449 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Reduce (SUM(1)) (10/11 ) 14:33:10,454 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Reduce (SUM(1)) (10/11) on dbis42 (ipcPort=37589, dataPort=5306 6) 14:33:10,463 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Reduce (SUM(1)) (10/ 11) 14:33:10,487 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task Reduce (SUM(1)) (11/11 ) 14:33:10,488 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task Reduce (SUM(1)) (11/11 ) 14:33:10,492 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task Reduce (SUM(1)) (11/11) on dbis43 (ipcPort=55584, dataPort=6051 2) 14:33:10,504 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task Reduce (SUM(1)) (11/ 11) 14:33:10,616 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (1/11) 14:33:10,632 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (9/11) 14:33:10,746 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (11/11) 14:33:10,748 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (5/11) 14:33:10,754 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (3/11) 14:33:10,833 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (10/11) 14:33:10,844 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (2/11) 14:33:10,903 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (4/11) 14:33:10,950 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (8/11) 14:33:11,003 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (7/11) 14:33:11,034 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CHAIN DataSource (T extInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.t xt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFrequ encies) -> Combine(SUM(1)) (6/11) 14:33:11,063 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task GroupReduce (eu.strato sphere.version6.MassJoinOriginJob$ReduceGroupTokenOrdering) (1/1) 14:33:11,064 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task GroupReduce (eu.strato sphere.version6.MassJoinOriginJob$ReduceGroupTokenOrdering) (1/1) 14:33:11,067 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task GroupReduce (eu.stratosphere.version6.MassJoinOriginJob$ReduceG roupTokenOrdering) (1/1) on dbis53 (ipcPort=40244, dataPort=36692) 14:33:11,079 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task GroupReduce (eu.stra tosphere.version6.MassJoinOriginJob$ReduceGroupTokenOrdering) (1/1) 14:33:11,578 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Reduce (SUM(1)) (11 /11) 14:33:11,579 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Reduce (SUM(1)) (2/ 11) 14:33:11,581 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Reduce (SUM(1)) (7/ 11) 14:33:11,582 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Reduce (SUM(1)) (1/ 11) 14:33:11,582 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Reduce (SUM(1)) (6/ 11) 14:33:11,585 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Reduce (SUM(1)) (4/ 11) 14:33:11,587 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Reduce (SUM(1)) (8/ 11) 14:33:11,587 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Reduce (SUM(1)) (10 /11) 14:33:11,588 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Reduce (SUM(1)) (5/ 11) 14:33:11,607 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Reduce (SUM(1)) (3/ 11) 14:33:11,887 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Reduce (SUM(1)) (9/ 11) 14:33:11,890 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (9/11) 14:33:11,890 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (5/11) 14:33:11,891 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (6/11) 14:33:11,891 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (1/11) 14:33:11,891 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (2/11) 14:33:11,892 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (8/11) 14:33:11,892 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (3/11) 14:33:11,892 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (7/11) 14:33:11,893 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (11/11) 14:33:11,893 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (10/11) 14:33:11,894 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CHAIN DataSource ( TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert. txt) - UTF-8) -> FlatMap (eu.stratosphere.version6.MassJoinOriginJob$FlatMapFreq uencies) -> Combine(SUM(1)) (4/11) 14:33:11,990 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (1/11) 14:33:11,990 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (1/11) 14:33:11,992 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esR) (1/11) on dbis53 (ipcPort=40244, dataPort=36692) 14:33:12,004 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesR) (1/11) 14:33:12,493 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (2/11) 14:33:12,494 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (2/11) 14:33:12,497 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esR) (2/11) on dbis52 (ipcPort=54052, dataPort=50177) 14:33:12,513 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesR) (2/11) 14:33:12,998 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (3/11) 14:33:12,998 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (3/11) 14:33:13,001 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esR) (3/11) on dbis64 (ipcPort=39772, dataPort=38106) 14:33:13,014 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesR) (3/11) 14:33:13,502 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (4/11) 14:33:13,503 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (4/11) 14:33:14,109 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esR) (4/11) on dbis54 (ipcPort=35437, dataPort=59613) 14:33:14,123 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesR) (4/11) 14:33:14,951 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (5/11) 14:33:14,951 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (5/11) 14:33:15,351 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esR) (5/11) on dbis51 (ipcPort=47708, dataPort=36810) 14:33:15,394 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesR) (5/11) 14:33:15,965 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (6/11) 14:33:15,966 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (6/11) 14:33:15,969 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esR) (6/11) on dbis61 (ipcPort=55971, dataPort=41778) 14:33:15,985 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesR) (6/11) 14:33:16,471 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (7/11) 14:33:16,471 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (7/11) 14:33:16,482 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esR) (7/11) on dbis44 (ipcPort=52319, dataPort=38155) 14:33:16,499 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesR) (7/11) 14:33:16,975 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (8/11) 14:33:16,976 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (8/11) 14:33:16,979 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esR) (8/11) on dbis63 (ipcPort=49848, dataPort=54262) 14:33:16,993 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesR) (8/11) 14:33:17,481 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (9/11) 14:33:17,481 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (9/11) 14:33:17,484 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esR) (9/11) on dbis62 (ipcPort=48523, dataPort=52932) 14:33:17,497 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesR) (9/11) 14:33:17,985 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (10/11) 14:33:17,986 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (10/11) 14:33:17,990 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esR) (10/11) on dbis42 (ipcPort=37589, dataPort=53066) 14:33:18,003 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesR) (10/11) 14:33:18,490 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (11/11) 14:33:18,490 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesR) (11/11) 14:33:18,494 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esR) (11/11) on dbis43 (ipcPort=55584, dataPort=60512) 14:33:18,507 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesR) (11/11) 14:33:18,994 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (1/11) 14:33:18,994 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (1/11) 14:33:18,997 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esS) (1/11) on dbis53 (ipcPort=40244, dataPort=36692) 14:33:19,005 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesS) (1/11) 14:33:19,498 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (2/11) 14:33:19,499 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (2/11) 14:33:19,502 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esS) (2/11) on dbis52 (ipcPort=54052, dataPort=50177) 14:33:19,509 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesS) (2/11) 14:33:20,003 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (3/11) 14:33:20,003 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (3/11) 14:33:20,247 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esS) (3/11) on dbis64 (ipcPort=39772, dataPort=38106) 14:33:20,257 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesS) (3/11) 14:33:20,508 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (4/11) 14:33:20,508 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (4/11) 14:33:20,512 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esS) (4/11) on dbis54 (ipcPort=35437, dataPort=59613) 14:33:20,523 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesS) (4/11) 14:33:21,011 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (5/11) 14:33:21,012 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (5/11) 14:33:21,611 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esS) (5/11) on dbis51 (ipcPort=47708, dataPort=36810) 14:33:21,620 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesS) (5/11) 14:33:21,876 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (6/11) 14:33:21,877 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (6/11) 14:33:21,882 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esS) (6/11) on dbis61 (ipcPort=55971, dataPort=41778) 14:33:21,892 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesS) (6/11) 14:33:22,832 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (7/11) 14:33:22,833 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (7/11) 14:33:22,837 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esS) (7/11) on dbis44 (ipcPort=52319, dataPort=38155) 14:33:22,848 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesS) (7/11) 14:33:23,336 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (8/11) 14:33:23,336 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (8/11) 14:33:23,340 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esS) (8/11) on dbis63 (ipcPort=49848, dataPort=54262) 14:33:23,349 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesS) (8/11) 14:33:23,840 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (9/11) 14:33:23,840 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (9/11) 14:33:23,845 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esS) (9/11) on dbis62 (ipcPort=48523, dataPort=52932) 14:33:23,856 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesS) (9/11) 14:33:24,344 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (10/11) 14:33:24,344 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (10/11) 14:33:24,348 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esS) (10/11) on dbis42 (ipcPort=37589, dataPort=53066) 14:33:24,356 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesS) (10/11) 14:33:24,850 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (11/11) 14:33:24,850 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task FlatMap (eu.stratosphe re.version6.MassJoinOriginJob$MapSignaturesS) (11/11) 14:33:24,853 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task FlatMap (eu.stratosphere.version6.MassJoinOriginJob$MapSignatur esS) (11/11) on dbis43 (ipcPort=55584, dataPort=60512) 14:33:24,870 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task FlatMap (eu.stratosp here.version6.MassJoinOriginJob$MapSignaturesS) (11/11) 14:33:25,455 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task GroupReduce (eu.str atosphere.version6.MassJoinOriginJob$ReduceGroupTokenOrdering) (1/1) 14:33:25,458 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Reduce (SUM(1)) (1 /11) 14:33:25,460 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Reduce (SUM(1)) (2 /11) 14:33:25,463 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Reduce (SUM(1)) (5 /11) 14:33:25,465 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Reduce (SUM(1)) (7 /11) 14:33:25,466 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Reduce (SUM(1)) (8 /11) 14:33:25,466 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Reduce (SUM(1)) (9 /11) 14:33:25,468 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Reduce (SUM(1)) (1 0/11) 14:33:25,469 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Reduce (SUM(1)) (1 1/11) 14:33:25,482 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Reduce (SUM(1)) (3 /11) 14:33:25,483 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Reduce (SUM(1)) (6 /11) 14:33:25,485 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Reduce (SUM(1)) (4 /11) 14:33:25,523 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (7/11) 14:33:25,523 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (7/11) 14:33:25,525 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (1/11) 14:33:25,525 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (1/11) 14:33:25,526 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupVeri fikation) (7/11) on dbis44 (ipcPort=52319, dataPort=38155) 14:33:25,529 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (11/11) 14:33:25,530 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (11/11) 14:33:25,530 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupVeri fikation) (1/11) on dbis53 (ipcPort=40244, dataPort=36692) 14:33:25,532 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupVeri fikation) (11/11) on dbis43 (ipcPort=55584, dataPort=60512) 14:33:25,538 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (6/11) 14:33:25,538 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (6/11) 14:33:25,539 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (3/11) 14:33:25,539 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (3/11) 14:33:25,542 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupVeri fikation) (6/11) on dbis61 (ipcPort=55971, dataPort=41778) 14:33:25,543 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupVeri fikation) (3/11) on dbis64 (ipcPort=39772, dataPort=38106) 14:33:25,554 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupVerifikation) (7/11) 14:33:25,566 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupVerifikation) (1/11) 14:33:25,573 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupVerifikation) (3/11) 14:33:25,574 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupVerifikation) (11/11) 14:33:25,584 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupVerifikation) (6/11) 14:33:25,600 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (9/11) 14:33:25,600 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (9/11) 14:33:25,601 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (2/11) 14:33:25,601 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (2/11) 14:33:25,603 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupVeri fikation) (9/11) on dbis62 (ipcPort=48523, dataPort=52932) 14:33:25,605 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupSign atures) (2/11) on dbis52 (ipcPort=54052, dataPort=50177) 14:33:25,614 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupVerifikation) (9/11) 14:33:25,624 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (9/11) 14:33:25,624 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (9/11) 14:33:25,624 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupSignatures) (2/11) 14:33:25,626 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupSign atures) (9/11) on dbis62 (ipcPort=48523, dataPort=52932) 14:33:25,628 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (5/11) 14:33:25,628 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (5/11) 14:33:25,631 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupSign atures) (5/11) on dbis51 (ipcPort=47708, dataPort=36810) 14:33:25,640 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupSignatures) (5/11) 14:33:25,652 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (6/11) 14:33:25,652 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (6/11) 14:33:25,654 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupSign atures) (6/11) on dbis61 (ipcPort=55971, dataPort=41778) 14:33:25,656 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (7/11) 14:33:25,657 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (7/11) 14:33:25,657 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupSignatures) (9/11) 14:33:25,659 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupSign atures) (7/11) on dbis44 (ipcPort=52319, dataPort=38155) 14:33:25,662 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (11/11) 14:33:25,663 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (11/11) 14:33:25,665 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupSign atures) (11/11) on dbis43 (ipcPort=55584, dataPort=60512) 14:33:25,668 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupSignatures) (7/11) 14:33:25,674 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (4/11) 14:33:25,675 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (4/11) 14:33:25,675 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupSignatures) (11/11) 14:33:25,678 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupSign atures) (4/11) on dbis54 (ipcPort=35437, dataPort=59613) 14:33:25,686 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupSignatures) (6/11) 14:33:25,688 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupSignatures) (4/11) 14:33:25,695 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (1/11) 14:33:25,696 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (1/11) 14:33:25,698 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupSign atures) (1/11) on dbis53 (ipcPort=40244, dataPort=36692) 14:33:25,702 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (8/11) 14:33:25,703 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (8/11) 14:33:25,705 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupSign atures) (8/11) on dbis63 (ipcPort=49848, dataPort=54262) 14:33:25,707 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupSignatures) (1/11) 14:33:25,714 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupSignatures) (8/11) 14:33:25,718 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (3/11) 14:33:25,719 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (3/11) 14:33:25,721 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupSign atures) (3/11) on dbis64 (ipcPort=39772, dataPort=38106) 14:33:25,729 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupSignatures) (3/11) 14:33:25,763 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (10/11) 14:33:25,763 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupSignatures) (10/11) 14:33:25,765 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupSign atures) (10/11) on dbis42 (ipcPort=37589, dataPort=53066) 14:33:25,774 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupSignatures) (10/11) 14:33:26,027 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (7/11) 14:33:26,027 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (7/11) 14:33:26,030 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupResu lt) (7/11) on dbis44 (ipcPort=52319, dataPort=38155) 14:33:26,040 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (6/11) 14:33:26,040 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (6/11) 14:33:26,043 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupResult) (7/11) 14:33:26,043 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupResu lt) (6/11) on dbis61 (ipcPort=55971, dataPort=41778) 14:33:26,044 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (3/11) 14:33:26,044 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (3/11) 14:33:26,046 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupResu lt) (3/11) on dbis64 (ipcPort=39772, dataPort=38106) 14:33:26,048 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (11/11) 14:33:26,048 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (11/11) 14:33:26,050 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupResu lt) (11/11) on dbis43 (ipcPort=55584, dataPort=60512) 14:33:26,050 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (1/11) 14:33:26,050 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (1/11) 14:33:26,052 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupResult) (6/11) 14:33:26,053 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupResu lt) (1/11) on dbis53 (ipcPort=40244, dataPort=36692) 14:33:26,054 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (2/11) 14:33:26,054 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (2/11) 14:33:26,056 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupVeri fikation) (2/11) on dbis52 (ipcPort=54052, dataPort=50177) 14:33:26,057 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupResult) (3/11) 14:33:26,060 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupResult) (11/11) 14:33:26,063 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupResult) (1/11) 14:33:26,066 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupVerifikation) (2/11) 14:33:26,081 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (2/11) 14:33:26,081 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (2/11) 14:33:26,083 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupResu lt) (2/11) on dbis52 (ipcPort=54052, dataPort=50177) 14:33:26,098 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupResult) (2/11) 14:33:26,103 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (9/11) 14:33:26,104 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (9/11) 14:33:26,395 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupResu lt) (9/11) on dbis62 (ipcPort=48523, dataPort=52932) 14:33:26,415 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupResult) (9/11) 14:33:26,434 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (5/11) 14:33:26,434 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (5/11) 14:33:26,436 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupVeri fikation) (5/11) on dbis51 (ipcPort=47708, dataPort=36810) 14:33:26,449 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupVerifikation) (5/11) 14:33:26,555 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (4/11) 14:33:26,556 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (4/11) 14:33:26,557 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupVeri fikation) (4/11) on dbis54 (ipcPort=35437, dataPort=59613) 14:33:26,565 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (8/11) 14:33:26,565 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (8/11) 14:33:26,568 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupVeri fikation) (8/11) on dbis63 (ipcPort=49848, dataPort=54262) 14:33:26,577 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupVerifikation) (4/11) 14:33:26,579 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (10/11) 14:33:26,579 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupVerifikation) (10/11) 14:33:26,579 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (4/11) 14:33:26,580 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (4/11) 14:33:26,581 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupVeri fikation) (10/11) on dbis42 (ipcPort=37589, dataPort=53066) 14:33:26,582 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupResu lt) (4/11) on dbis54 (ipcPort=35437, dataPort=59613) 14:33:26,594 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupResult) (4/11) 14:33:26,604 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupVerifikation) (8/11) 14:33:26,608 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupVerifikation) (10/11) 14:33:26,616 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (5/11) 14:33:26,616 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (5/11) 14:33:26,619 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupResu lt) (5/11) on dbis51 (ipcPort=47708, dataPort=36810) 14:33:26,626 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (10/11) 14:33:26,627 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (10/11) 14:33:26,629 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupResult) (5/11) 14:33:26,629 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupResu lt) (10/11) on dbis42 (ipcPort=37589, dataPort=53066) 14:33:26,639 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupResult) (10/11) 14:33:27,098 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (8/11) 14:33:27,098 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task CoGroup (eu.stratosphe re.version6.MassJoinOriginJob$CoGroupResult) (8/11) 14:33:27,101 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task CoGroup (eu.stratosphere.version6.MassJoinOriginJob$CoGroupResu lt) (8/11) on dbis63 (ipcPort=49848, dataPort=54262) 14:33:27,111 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task CoGroup (eu.stratosp here.version6.MassJoinOriginJob$CoGroupResult) (8/11) 14:35:32,562 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (10/11) 14:35:33,536 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (4/11) 14:35:34,021 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (9/11) 14:35:34,376 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (3/11) 14:35:34,505 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (7/11) 14:35:34,689 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (10/11) 14:35:34,691 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (10/11) 14:35:34,693 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (10/11) 14:35:35,333 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (4/11) 14:35:35,334 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (4/11) 14:35:35,337 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (4/11) 14:35:35,717 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (9/11) 14:35:35,718 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (9/11) 14:35:35,720 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (9/11) 14:35:35,918 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (10/11) 14:35:36,161 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (3/11) 14:35:36,162 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (3/11) 14:35:36,164 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (3/11) 14:35:36,209 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (7/11) 14:35:36,210 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (7/11) 14:35:36,212 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (7/11) 14:35:36,576 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (8/11) 14:35:36,665 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (4/11) 14:35:37,032 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (5/11) 14:35:37,068 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (9/11) 14:35:37,358 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (3/11) 14:35:37,473 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (7/11) 14:35:37,849 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (11/11) 14:35:38,174 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (2/11) 14:35:38,289 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (8/11) 14:35:38,292 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (8/11) 14:35:38,294 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (8/11) 14:35:38,981 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (5/11) 14:35:38,983 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (5/11) 14:35:38,985 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (5/11) 14:35:39,248 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (11/11) 14:35:39,251 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (11/11) 14:35:39,279 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (11/11) 14:35:39,740 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (8/11) 14:35:40,027 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (2/11) 14:35:40,029 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (2/11) 14:35:40,030 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (2/11) 14:35:40,331 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (5/11) 14:35:40,389 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (11/11) 14:35:40,660 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (1/11) 14:35:41,307 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (2/11) 14:35:42,148 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (1/11) 14:35:42,150 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (1/11) 14:35:42,152 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (1/11) 14:35:42,238 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSource (TextInp utFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (6/11) 14:35:43,172 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (1/11) 14:35:43,907 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task Map (eu.stratospher e.version6.MassJoinOriginJob$SplitNMapper) (6/11) 14:35:43,908 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSource (TextIn putFormat (file:/home/hoenicke/flink-0.6-incubating/input/inputNummeriert.txt) - UTF-8) (6/11) 14:35:43,910 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesR) (6/11) 14:35:45,278 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task FlatMap (eu.stratos phere.version6.MassJoinOriginJob$MapSignaturesS) (6/11) 14:35:47,711 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task GroupReduce (eu.st ratosphere.version6.MassJoinOriginJob$ReduceGroupTokenOrdering) (1/1) 14:36:31,298 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (1/11) 14:36:36,488 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (2/11) 14:36:38,763 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (10/11) 14:36:39,116 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (3/11) 14:36:39,236 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (6/11) 14:36:40,298 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (7/11) 14:36:41,600 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (5/11) 14:36:43,170 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (4/11) 14:36:43,185 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (8/11) 14:36:52,326 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (9/11) 14:39:03,093 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupSignatures) (11/11) 14:39:03,097 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (1/11) 14:39:03,098 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (2/11) 14:39:03,099 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (3/11) 14:39:03,099 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (4/11) 14:39:03,100 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (5/11) 14:39:03,101 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (6/11) 14:39:03,103 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (8/11) 14:39:03,103 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (7/11) 14:39:03,104 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (11/11) 14:39:03,104 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (9/11) 14:39:03,105 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesR) (10/11) 14:39:03,105 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (1/11) 14:39:03,107 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (2/11) 14:39:03,107 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (3/11) 14:39:03,107 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (4/11) 14:39:03,109 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (5/11) 14:39:03,109 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (6/11) 14:39:03,110 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (7/11) 14:39:03,110 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (8/11) 14:39:03,112 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (11/11) 14:39:03,112 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (9/11) 14:39:03,112 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task FlatMap (eu.strato sphere.version6.MassJoinOriginJob$MapSignaturesS) (10/11) 14:43:28,366 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (6/11) 14:43:29,024 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (7/11) 14:43:32,855 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (8/11) 14:43:38,979 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (3/11) 14:43:39,656 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (4/11) 14:43:42,813 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (11/11) 14:43:54,906 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (9/11) 14:43:55,958 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (2/11) 14:44:09,320 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (5/11) 14:44:33,448 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (10/11) 14:44:49,189 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupVerifikation) (1/11) 14:44:49,192 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (1/11) 14:44:49,195 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (3/11) 14:44:49,196 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (4/11) 14:44:49,202 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (6/11) 14:44:49,203 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (7/11) 14:44:49,203 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (8/11) 14:44:49,204 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (9/11) 14:44:49,204 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (5/11) 14:44:49,209 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (11/11) 14:44:49,212 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (10/11) 14:44:49,512 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupSignatures) (2/11) 14:52:49,365 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (2/11) 14:52:49,365 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (2/11) 14:52:49,369 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incuba ting/output) - UTF-8) (2/11) on dbis52 (ipcPort=54052, dataPort=50177) 14:52:49,405 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSink(TextOutputF ormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (2/11) 14:52:50,610 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (2/11) 14:52:50,628 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (2/11) 14:52:50,629 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (2/11) 14:52:50,630 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (2/11) 14:52:59,826 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (5/11) 14:52:59,826 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (5/11) 14:52:59,830 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incuba ting/output) - UTF-8) (5/11) on dbis51 (ipcPort=47708, dataPort=36810) 14:52:59,873 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSink(TextOutputF ormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (5/11) 14:53:01,096 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (5/11) 14:53:01,115 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (5/11) 14:53:01,116 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (5/11) 14:53:01,117 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (5/11) 14:53:45,836 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (9/11) 14:53:45,836 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (9/11) 14:53:45,839 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incuba ting/output) - UTF-8) (9/11) on dbis62 (ipcPort=48523, dataPort=52932) 14:53:45,874 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSink(TextOutputF ormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (9/11) 14:53:47,050 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (9/11) 14:53:47,071 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (9/11) 14:53:47,072 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (9/11) 14:53:47,073 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (9/11) 14:54:42,170 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (7/11) 14:54:42,170 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (7/11) 14:54:42,173 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incuba ting/output) - UTF-8) (7/11) on dbis44 (ipcPort=52319, dataPort=38155) 14:54:42,188 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSink(TextOutputF ormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (7/11) 14:54:43,401 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (7/11) 14:54:43,416 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (7/11) 14:54:43,417 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (7/11) 14:54:43,417 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (7/11) 14:54:48,234 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (3/11) 14:54:48,234 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (3/11) 14:54:48,238 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incuba ting/output) - UTF-8) (3/11) on dbis64 (ipcPort=39772, dataPort=38106) 14:54:48,273 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSink(TextOutputF ormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (3/11) 14:54:49,508 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (3/11) 14:54:49,525 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (3/11) 14:54:49,526 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (3/11) 14:54:49,526 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (3/11) 14:55:22,582 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (10/11) 14:55:22,583 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (10/11) 14:55:22,586 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incuba ting/output) - UTF-8) (10/11) on dbis42 (ipcPort=37589, dataPort=53066) 14:55:22,606 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSink(TextOutputF ormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (10/11) 14:55:23,822 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (10/11) 14:55:23,842 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (10/11) 14:55:23,844 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (10/11) 14:55:23,844 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (10/11) 14:55:28,245 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (8/11) 14:55:28,245 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (8/11) 14:55:28,248 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incuba ting/output) - UTF-8) (8/11) on dbis63 (ipcPort=49848, dataPort=54262) 14:55:28,285 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSink(TextOutputF ormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (8/11) 14:55:29,494 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (8/11) 14:55:29,514 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (8/11) 14:55:29,516 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (8/11) 14:55:29,516 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (8/11) 14:56:12,302 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (11/11) 14:56:12,302 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (11/11) 14:56:12,305 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incuba ting/output) - UTF-8) (11/11) on dbis43 (ipcPort=55584, dataPort=60512) 14:56:12,317 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSink(TextOutputF ormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (11/11) 14:56:13,558 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (11/11) 14:56:13,576 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (11/11) 14:56:13,578 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (11/11) 14:56:13,579 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (11/11) 14:56:31,337 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (4/11) 14:56:31,337 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (4/11) 14:56:31,341 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incuba ting/output) - UTF-8) (4/11) on dbis54 (ipcPort=35437, dataPort=59613) 14:56:31,382 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSink(TextOutputF ormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (4/11) 14:56:32,599 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (4/11) 14:56:32,618 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (4/11) 14:56:32,619 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (4/11) 14:56:32,620 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (4/11) 14:58:15,256 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (1/11) 14:58:15,257 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (1/11) 14:58:15,260 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incuba ting/output) - UTF-8) (1/11) on dbis53 (ipcPort=40244, dataPort=36692) 14:58:15,301 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSink(TextOutputF ormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (1/11) 14:58:16,545 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (1/11) 14:58:16,563 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (1/11) 14:58:16,564 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (1/11) 14:58:16,564 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (1/11) 14:59:50,171 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from ASSIGNED to READY for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (6/11) 14:59:50,172 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from READY to STARTING for task DataSink(TextOutputFor mat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (6/11) 14:59:50,175 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting task DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incuba ting/output) - UTF-8) (6/11) on dbis61 (ipcPort=55971, dataPort=41778) 14:59:50,208 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from STARTING to RUNNING for task DataSink(TextOutputF ormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (6/11) 14:59:51,399 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task CoGroup (eu.stratos phere.version6.MassJoinOriginJob$CoGroupResult) (6/11) 14:59:51,403 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (1/11) 14:59:51,404 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (2/11) 14:59:51,405 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (6/11) 14:59:51,405 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (4/11) 14:59:51,406 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (3/11) 14:59:51,406 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (5/11) 14:59:51,408 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (7/11) 14:59:51,408 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (8/11) 14:59:51,409 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (9/11) 14:59:51,410 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (10/11) 14:59:51,410 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (1/11) 14:59:51,410 INFO org.apache.flink.runtime.jobmanager.scheduler.DefaultSchedule r - Releasing instance dbis53 (ipcPort=40244, dataPort=36692) 14:59:51,411 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (2/11) 14:59:51,411 INFO org.apache.flink.runtime.jobmanager.scheduler.DefaultSchedule r - Releasing instance dbis52 (ipcPort=54052, dataPort=50177) 14:59:51,412 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupVerifikation) (11/11) 14:59:51,412 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (3/11) 14:59:51,412 INFO org.apache.flink.runtime.jobmanager.scheduler.DefaultSchedule r - Releasing instance dbis64 (ipcPort=39772, dataPort=38106) 14:59:51,413 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (4/11) 14:59:51,413 INFO org.apache.flink.runtime.jobmanager.scheduler.DefaultSchedule r - Releasing instance dbis54 (ipcPort=35437, dataPort=59613) 14:59:51,413 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (6/11) 14:59:51,414 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (5/11) 14:59:51,414 INFO org.apache.flink.runtime.jobmanager.scheduler.DefaultSchedule r - Releasing instance dbis51 (ipcPort=47708, dataPort=36810) 14:59:51,414 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (7/11) 14:59:51,414 INFO org.apache.flink.runtime.jobmanager.scheduler.DefaultSchedule r - Releasing instance dbis44 (ipcPort=52319, dataPort=38155) 14:59:51,415 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (8/11) 14:59:51,415 INFO org.apache.flink.runtime.jobmanager.scheduler.DefaultSchedule r - Releasing instance dbis63 (ipcPort=49848, dataPort=54262) 14:59:51,416 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (9/11) 14:59:51,416 INFO org.apache.flink.runtime.jobmanager.scheduler.DefaultSchedule r - Releasing instance dbis62 (ipcPort=48523, dataPort=52932) 14:59:51,416 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from RUNNING to FINISHING for task DataSink(TextOutput Format (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (6/11) 14:59:51,416 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (10/11) 14:59:51,417 INFO org.apache.flink.runtime.jobmanager.scheduler.DefaultSchedule r - Releasing instance dbis42 (ipcPort=37589, dataPort=53066) 14:59:51,417 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task DataSink(TextOutpu tFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (6/11) 14:59:51,417 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task Map (eu.stratosphe re.version6.MassJoinOriginJob$SplitNMapper) (11/11) 14:59:51,418 INFO org.apache.flink.runtime.jobmanager.scheduler.DefaultSchedule r - Releasing instance dbis43 (ipcPort=55584, dataPort=60512) 14:59:51,418 INFO org.apache.flink.runtime.execution.ExecutionStateTransition - JM: ExecutionState set from FINISHING to FINISHED for task CoGroup (eu.strato sphere.version6.MassJoinOriginJob$CoGroupResult) (6/11) 14:59:51,418 INFO org.apache.flink.runtime.jobmanager.scheduler.DefaultSchedule r - Releasing instance dbis61 (ipcPort=55971, dataPort=41778) 14:59:51,422 INFO org.apache.flink.runtime.jobmanager.JobManager - Status of job WordCount Example(0c24a6d2539640005ccbb5b34adb6400) changed to FINISHED