Imagine the following job graph with an applied constraint:
input.connectTo(task1);
input.connectTo(task2);
task1.connectTo(task3);
task2.connectTo(task3);
task3.connectTo(output1);
ConstraintUtil.defineAllLatencyConstraintsBetween(input, output, 100);
where input creates random data and task1, task2, task3 pass the data through to the output.
Whenever input terminates (regularly) task1 throws the following exception:
ERROR eu.stratosphere.nephele.taskmanager.bytebuffered.IncomingConnection - java.io.IOException: Invalid buffer size: 0
at eu.stratosphere.nephele.taskmanager.transferenvelope.AbstractDeserializer.readBuffer(AbstractDeserializer.java:298)
at eu.stratosphere.nephele.taskmanager.transferenvelope.AbstractDeserializer.read(AbstractDeserializer.java:97)
at eu.stratosphere.nephele.taskmanager.bytebuffered.IncomingConnection.read(IncomingConnection.java:91)
at eu.stratosphere.nephele.taskmanager.bytebuffered.IncomingConnectionThread.doRead(IncomingConnectionThread.java:187)
at eu.stratosphere.nephele.taskmanager.bytebuffered.IncomingConnectionThread.run(IncomingConnectionThread.java:126)
Imagine the following job graph with an applied constraint:
where
inputcreates random data andtask1,task2,task3pass the data through to theoutput.Whenever
inputterminates (regularly)task1throws the following exception: