Hi,
I get a runtime error while executing my flink0.6 job.
"An error occurred in the channel"
Could anyone help me?
Greetings
Florian
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)
