10/08/2014 14:14:22:    Job execution switched to status SCHEDULED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (1/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (1/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (1/11) switched to SCHEDULED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (1/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (1/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(Print to System.out) (1/11) switched to SCHEDULED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (2/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (2/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(Print to System.out) (2/11) switched to SCHEDULED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (3/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (3/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(Print to System.out) (3/11) switched to SCHEDULED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (4/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (4/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(Print to System.out) (4/11) switched to SCHEDULED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (5/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (5/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(Print to System.out) (5/11) switched to SCHEDULED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (6/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (6/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(Print to System.out) (6/11) switched to SCHEDULED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (7/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (7/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(Print to System.out) (7/11) switched to SCHEDULED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (8/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (8/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(Print to System.out) (8/11) switched to SCHEDULED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (9/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (9/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(Print to System.out) (9/11) switched to SCHEDULED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (10/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (10/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(Print to System.out) (10/11) switched to SCHEDULED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (11/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (11/11) switched to SCHEDULED
10/08/2014 14:14:22:    DataSink(Print to System.out) (11/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (2/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (3/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (4/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (5/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (6/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (7/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (8/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (9/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (10/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (11/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (2/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (3/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (4/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (5/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (6/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (7/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (8/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (9/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (10/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (11/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (2/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (3/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (4/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (5/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (6/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (7/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (8/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (9/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (10/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (11/11) switched to SCHEDULED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (1/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (1/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(Print to System.out) (1/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (1/11) switched to ASSIGNED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (1/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (1/11) switched to ASSIGNED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (2/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (2/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (2/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (2/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(Print to System.out) (2/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (2/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(Print to System.out) (3/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (3/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (3/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (3/11) switched to ASSIGNED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (3/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (3/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (4/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (4/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (4/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (4/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(Print to System.out) (4/11) switched to ASSIGNED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (4/11) switched to ASSIGNED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (5/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(Print to System.out) (5/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (5/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (5/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (5/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (5/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (6/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (6/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (6/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (6/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(Print to System.out) (6/11) switched to ASSIGNED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (6/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (7/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (7/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (7/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (7/11) switched to ASSIGNED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (7/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(Print to System.out) (7/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (8/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (8/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (8/11) switched to ASSIGNED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (8/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (8/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(Print to System.out) (8/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(Print to System.out) (9/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (9/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (9/11) switched to ASSIGNED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (9/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (9/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (9/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (10/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (10/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (10/11) switched to ASSIGNED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (10/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(Print to System.out) (10/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (10/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (11/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (11/11) switched to ASSIGNED
10/08/2014 14:14:22:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (11/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (11/11) switched to ASSIGNED
10/08/2014 14:14:22:    DataSink(Print to System.out) (11/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (11/11) switched to ASSIGNED
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (1/11) switched to READY
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (2/11) switched to READY
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (3/11) switched to READY
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (4/11) switched to READY
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (5/11) switched to READY
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (6/11) switched to READY
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (7/11) switched to READY
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (8/11) switched to READY
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (9/11) switched to READY
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (10/11) switched to READY
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (11/11) switched to READY
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (1/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (2/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (4/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (3/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (5/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (7/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (6/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (9/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (8/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (11/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (10/11) switched to STARTING
10/08/2014 14:14:22:    Job execution switched to status RUNNING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (11/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (1/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (8/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (9/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (4/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (5/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (3/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (2/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (6/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (7/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (10/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (6/11) switched to READY
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (6/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (5/11) switched to READY
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (5/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (1/11) switched to READY
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (1/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (8/11) switched to READY
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (8/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (6/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (5/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (3/11) switched to READY
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (3/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (7/11) switched to READY
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (7/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (11/11) switched to READY
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (11/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (1/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (8/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (9/11) switched to READY
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (9/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (3/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (11/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (7/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (9/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (4/11) switched to READY
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (4/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (2/11) switched to READY
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (2/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (4/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (2/11) switched to RUNNING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (10/11) switched to READY
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (10/11) switched to STARTING
10/08/2014 14:14:22:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (10/11) switched to RUNNING
10/08/2014 14:14:23:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (5/11) switched to FINISHING
10/08/2014 14:14:23:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (10/11) switched to FINISHING
10/08/2014 14:14:23:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (6/11) switched to FINISHING
10/08/2014 14:14:23:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (8/11) switched to FINISHING
10/08/2014 14:14:23:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (9/11) switched to FINISHING
10/08/2014 14:14:23:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (11/11) switched to FINISHING
10/08/2014 14:14:23:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (2/11) switched to FINISHING
10/08/2014 14:14:23:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (7/11) switched to FINISHING
10/08/2014 14:14:23:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (4/11) switched to FINISHING
10/08/2014 14:14:23:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (3/11) switched to FINISHING
10/08/2014 14:14:23:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (1/11) switched to FINISHING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (3/11) switched to READY
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (3/11) switched to STARTING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (11/11) switched to READY
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (11/11) switched to STARTING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (3/11) switched to RUNNING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (11/11) switched to RUNNING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (7/11) switched to READY
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (7/11) switched to STARTING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (10/11) switched to READY
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (10/11) switched to STARTING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (10/11) switched to RUNNING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (7/11) switched to RUNNING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (5/11) switched to READY
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (5/11) switched to STARTING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (5/11) switched to RUNNING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (6/11) switched to READY
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (6/11) switched to STARTING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (6/11) switched to RUNNING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (1/11) switched to READY
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (1/11) switched to STARTING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (1/11) switched to RUNNING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (8/11) switched to READY
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (8/11) switched to STARTING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (8/11) switched to RUNNING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (2/11) switched to READY
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (2/11) switched to STARTING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (9/11) switched to READY
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (9/11) switched to STARTING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (2/11) switched to RUNNING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (9/11) switched to RUNNING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (4/11) switched to READY
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (4/11) switched to STARTING
10/08/2014 14:14:24:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (4/11) switched to RUNNING
10/08/2014 14:14:25:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (7/11) switched to FINISHING
10/08/2014 14:14:25:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (10/11) switched to FINISHING
10/08/2014 14:14:25:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (8/11) switched to FINISHING
10/08/2014 14:14:25:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (2/11) switched to FINISHING
10/08/2014 14:14:25:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (1/11) switched to FINISHING
10/08/2014 14:14:25:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (3/11) switched to FINISHING
10/08/2014 14:14:25:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (5/11) switched to FINISHING
10/08/2014 14:14:25:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (11/11) switched to FINISHING
10/08/2014 14:14:25:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (4/11) switched to FINISHING
10/08/2014 14:14:25:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (9/11) switched to FINISHING
10/08/2014 14:14:25:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (6/11) switched to FINISHING
10/08/2014 14:14:25:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (6/11) switched to FINISHED
10/08/2014 14:14:25:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (3/11) switched to FINISHED
10/08/2014 14:14:25:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (1/11) switched to FINISHED
10/08/2014 14:14:25:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (4/11) switched to FINISHED
10/08/2014 14:14:25:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (2/11) switched to FINISHED
10/08/2014 14:14:25:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (7/11) switched to FINISHED
10/08/2014 14:14:25:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (5/11) switched to FINISHED
10/08/2014 14:14:25:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (9/11) switched to FINISHED
10/08/2014 14:14:25:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (10/11) switched to FINISHED
10/08/2014 14:14:25:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (8/11) switched to FINISHED
10/08/2014 14:14:25:    CHAIN DataSource (TextInputFormat (file:/home/hoenicke/flink-0.6-incubating/input/set20000.txt) - UTF-8) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapOnline) (11/11) switched to FINISHED
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (2/11) switched to READY
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (2/11) switched to STARTING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (2/11) switched to RUNNING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (7/11) switched to READY
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (7/11) switched to STARTING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (7/11) switched to RUNNING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (3/11) switched to READY
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (3/11) switched to STARTING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (3/11) switched to RUNNING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (11/11) switched to READY
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (11/11) switched to STARTING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (1/11) switched to READY
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (1/11) switched to STARTING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (11/11) switched to RUNNING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (1/11) switched to RUNNING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (8/11) switched to READY
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (8/11) switched to STARTING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (6/11) switched to READY
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (6/11) switched to STARTING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (10/11) switched to READY
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (10/11) switched to STARTING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (8/11) switched to RUNNING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (6/11) switched to RUNNING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (10/11) switched to RUNNING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (9/11) switched to READY
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (9/11) switched to STARTING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (5/11) switched to READY
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (5/11) switched to STARTING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (9/11) switched to RUNNING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (5/11) switched to RUNNING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (4/11) switched to READY
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (4/11) switched to STARTING
10/08/2014 14:14:26:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (4/11) switched to RUNNING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (1/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (1/11) switched to CANCELING
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (1/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (1/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (1/11) switched to CANCELED
10/08/2014 14:16:27:    DataSink(Print to System.out) (1/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(Print to System.out) (1/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (2/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (2/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (2/11) switched to CANCELED
10/08/2014 14:16:27:    DataSink(Print to System.out) (2/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(Print to System.out) (2/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (3/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (3/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (3/11) switched to CANCELED
10/08/2014 14:16:27:    DataSink(Print to System.out) (3/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(Print to System.out) (3/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (4/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (4/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (4/11) switched to CANCELED
10/08/2014 14:16:27:    DataSink(Print to System.out) (4/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(Print to System.out) (4/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (5/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (5/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (5/11) switched to CANCELED
10/08/2014 14:16:27:    DataSink(Print to System.out) (5/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(Print to System.out) (5/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (6/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (6/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (6/11) switched to CANCELED
10/08/2014 14:16:27:    DataSink(Print to System.out) (6/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(Print to System.out) (6/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (7/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (7/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (7/11) switched to CANCELED
10/08/2014 14:16:27:    DataSink(Print to System.out) (7/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(Print to System.out) (7/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (8/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (8/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (8/11) switched to CANCELED
10/08/2014 14:16:27:    DataSink(Print to System.out) (8/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(Print to System.out) (8/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (9/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (9/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (9/11) switched to CANCELED
10/08/2014 14:16:27:    DataSink(Print to System.out) (9/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(Print to System.out) (9/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (10/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (10/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (10/11) switched to CANCELED
10/08/2014 14:16:27:    DataSink(Print to System.out) (10/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(Print to System.out) (10/11) switched to CANCELED
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (11/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(TextOutputFormat (file:/home/hoenicke/flink-0.6-incubating/output) - UTF-8) (11/11) switched to CANCELED
10/08/2014 14:16:27:    DataSink(Print to System.out) (11/11) switched to CANCELING
10/08/2014 14:16:27:    DataSink(Print to System.out) (11/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (2/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (3/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (4/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (5/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (6/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (7/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (8/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (9/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (10/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (11/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (2/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (3/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (4/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (5/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (6/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (7/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (8/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (9/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (10/11) switched to CANCELING
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (11/11) switched to CANCELING
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (11/11) switched to FAILED
java.lang.Exception: The data preparation for task 'Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2)' , caused an error: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: An error occurred in the channel: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:485)
        at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:375)
        at org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:265)
        at java.lang.Thread.run(Thread.java:744)
Caused by: java.lang.RuntimeException: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: An error occurred in the channel: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:616)
        at org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
        at org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:91)
        at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:480)
        ... 3 more
Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' terminated due to an exception: An error occurred in the channel: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:801)
Caused by: java.io.IOException: An error occurred in the channel: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.io.network.channels.InputChannel.isClosed(InputChannel.java:208)
        at org.apache.flink.runtime.io.network.channels.InputChannel.readRecord(InputChannel.java:140)
        at org.apache.flink.runtime.io.network.gates.InputGate.readRecord(InputGate.java:178)
        at org.apache.flink.runtime.io.network.api.MutableRecordReader.next(MutableRecordReader.java:51)
        at org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:53)
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:1034)
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:798)
Caused by: java.io.IOException: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.io.network.channels.InputChannel.queueEnvelope(InputChannel.java:308)
        at org.apache.flink.runtime.io.network.ChannelManager.dispatchFromNetwork(ChannelManager.java:578)
        at org.apache.flink.runtime.io.network.netty.InboundEnvelopeDispatcher.channelRead(InboundEnvelopeDispatcher.java:40)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
        at org.apache.flink.runtime.io.network.netty.InboundEnvelopeDecoder.decodeBuffer(InboundEnvelopeDecoder.java:129)
        at org.apache.flink.runtime.io.network.netty.InboundEnvelopeDecoder.channelRead(InboundEnvelopeDecoder.java:111)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
        at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787)
        at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:125)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
        at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
        at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
        at java.lang.Thread.run(Thread.java:744)

10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (11/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (1/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (9/11) switched to FAILED
java.lang.Exception: The data preparation for task 'Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2)' , caused an error: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: An error occurred in the channel: Expected data packet 5758 but received 5765
        at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:485)
        at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:375)
        at org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:265)
        at java.lang.Thread.run(Thread.java:744)
Caused by: java.lang.RuntimeException: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: An error occurred in the channel: Expected data packet 5758 but received 5765
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:616)
        at org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
        at org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:91)
        at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:480)
        ... 3 more
Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' terminated due to an exception: An error occurred in the channel: Expected data packet 5758 but received 5765
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:801)
Caused by: java.io.IOException: An error occurred in the channel: Expected data packet 5758 but received 5765
        at org.apache.flink.runtime.io.network.channels.InputChannel.isClosed(InputChannel.java:208)
        at org.apache.flink.runtime.io.network.channels.InputChannel.readRecord(InputChannel.java:140)
        at org.apache.flink.runtime.io.network.gates.InputGate.readRecord(InputGate.java:178)
        at org.apache.flink.runtime.io.network.api.MutableRecordReader.next(MutableRecordReader.java:51)
        at org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:53)
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:1034)
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:798)
Caused by: java.io.IOException: Expected data packet 5758 but received 5765
        at org.apache.flink.runtime.io.network.channels.InputChannel.queueEnvelope(InputChannel.java:308)
        at org.apache.flink.runtime.io.network.ChannelManager.dispatchFromNetwork(ChannelManager.java:578)
        at org.apache.flink.runtime.io.network.netty.InboundEnvelopeDispatcher.channelRead(InboundEnvelopeDispatcher.java:40)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
        at org.apache.flink.runtime.io.network.netty.InboundEnvelopeDecoder.decodeBuffer(InboundEnvelopeDecoder.java:129)
        at org.apache.flink.runtime.io.network.netty.InboundEnvelopeDecoder.channelRead(InboundEnvelopeDecoder.java:111)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
        at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787)
        at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:125)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
        at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
        at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
        at java.lang.Thread.run(Thread.java:744)

10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (9/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (2/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (1/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (3/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (1/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (4/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (4/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (5/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (3/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (8/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (2/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (5/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (7/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (8/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (2/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (10/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (3/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (4/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (5/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (10/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim1) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim2) (7/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (7/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (8/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (9/11) switched to CANCELED
10/08/2014 14:16:27:    Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2) (6/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (10/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (11/11) switched to CANCELED
10/08/2014 14:16:27:    CHAIN Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceOnline) -> Map (eu.stratosphere.flink6.HadoopMultiFlink6Job$MapSim1) (6/11) switched to CANCELED
10/08/2014 14:16:27:    Job execution switched to status FAILED
Error: The program execution failed: java.lang.Exception: The data preparation for task 'Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2)' , caused an error: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: An error occurred in the channel: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:485)
        at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:375)
        at org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:265)
        at java.lang.Thread.run(Thread.java:744)
Caused by: java.lang.RuntimeException: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: An error occurred in the channel: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:616)
        at org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
        at org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:91)
        at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:480)
        ... 3 more
Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' terminated due to an exception: An error occurred in the channel: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:801)
Caused by: java.io.IOException: An error occurred in the channel: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.io.network.channels.InputChannel.isClosed(InputChannel.java:208)
        at org.apache.flink.runtime.io.network.channels.InputChannel.readRecord(InputChannel.java:140)
        at org.apache.flink.runtime.io.network.gates.InputGate.readRecord(InputGate.java:178)
        at org.apache.flink.runtime.io.network.api.MutableRecordReader.next(MutableRecordReader.java:51)
        at org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:53)
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:1034)
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:798)
Caused by: java.io.IOException: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.io.network.channels.InputChannel.queueEnvelope(InputChannel.java:308)
        at org.apache.flink.runtime.io.network.ChannelManager.dispatchFromNetwork(ChannelManager.java:578)
        at org.apache.flink.runtime.io.network.netty.InboundEnvelopeDispatcher.channelRead(InboundEnvelopeDispatcher.java:40)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
        at org.apache.flink.runtime.io.network.netty.InboundEnvelopeDecoder.decodeBuffer(InboundEnvelopeDecoder.java:129)
        at org.apache.flink.runtime.io.network.netty.InboundEnvelopeDecoder.channelRead(InboundEnvelopeDecoder.java:111)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
        at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787)
        at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:125)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
        at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
        at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
        at java.lang.Thread.run(Thread.java:744)

org.apache.flink.client.program.ProgramInvocationException: The program execution failed: java.lang.Exception: The data preparation for task 'Reduce(eu.stratosphere.flink6.HadoopMultiFlink6Job$ReduceSim2)' , caused an error: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: An error occurred in the channel: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:485)
        at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:375)
        at org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:265)
        at java.lang.Thread.run(Thread.java:744)
Caused by: java.lang.RuntimeException: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: An error occurred in the channel: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:616)
        at org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
        at org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:91)
        at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:480)
        ... 3 more
Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' terminated due to an exception: An error occurred in the channel: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:801)
Caused by: java.io.IOException: An error occurred in the channel: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.io.network.channels.InputChannel.isClosed(InputChannel.java:208)
        at org.apache.flink.runtime.io.network.channels.InputChannel.readRecord(InputChannel.java:140)
        at org.apache.flink.runtime.io.network.gates.InputGate.readRecord(InputGate.java:178)
        at org.apache.flink.runtime.io.network.api.MutableRecordReader.next(MutableRecordReader.java:51)
        at org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:53)
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:1034)
        at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:798)
Caused by: java.io.IOException: Expected data packet 11707 but received 11740
        at org.apache.flink.runtime.io.network.channels.InputChannel.queueEnvelope(InputChannel.java:308)
        at org.apache.flink.runtime.io.network.ChannelManager.dispatchFromNetwork(ChannelManager.java:578)
        at org.apache.flink.runtime.io.network.netty.InboundEnvelopeDispatcher.channelRead(InboundEnvelopeDispatcher.java:40)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
        at org.apache.flink.runtime.io.network.netty.InboundEnvelopeDecoder.decodeBuffer(InboundEnvelopeDecoder.java:129)
        at org.apache.flink.runtime.io.network.netty.InboundEnvelopeDecoder.channelRead(InboundEnvelopeDecoder.java:111)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
        at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787)
        at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:125)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
        at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
        at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
        at java.lang.Thread.run(Thread.java:744)

        at org.apache.flink.client.program.Client.run(Client.java:325)
        at org.apache.flink.client.program.Client.run(Client.java:291)
        at org.apache.flink.client.program.Client.run(Client.java:285)
        at org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:54)
        at eu.stratosphere.flink6.HadoopMultiFlink6Job.main(HadoopMultiFlink6Job.java:57)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
        at java.lang.reflect.Method.invoke(Method.java:597)
        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:389)
        at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:307)
        at org.apache.flink.client.program.Client.run(Client.java:244)
        at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:332)
        at org.apache.flink.client.CliFrontend.run(CliFrontend.java:319)
        at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:930)
        at org.apache.flink.client.CliFrontend.main(CliFrontend.java:954)