Hi,
I am working on FLINK-1870 and my changes break some unit tests. The
problem is in streaming.api.IterateTest.
I tracked the problem down to StreamTask.registerInputOutput(). It calls
headOperator.setup(...). My changes depend on this call, however, there
is no head operator (ie, ==null), and the call to setup(...) is not
made. Thus, for one operator the StreamingRuntimeContext member variable
"runtimeConext" is not initialized (ie, is null) and the test fails with
a NPE.
Can you give a short explanation about those code parts? What is the
condition for a missing headOperator? How can I ensure, that setup() is
called for all operators?
You can find my code here:
https://github.com/mjsax/flink/tree/flink-1870-inputChannelIndexThanks! And happy new year!
-Matthias