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-inputChannelIndex Thanks! And happy new year! -Matthias
signature.asc
Description: OpenPGP digital signature
