Hi, the iteration operators (head and tail) don't have a StreamOperator, they are pure tasks.
On Sat, Jan 2, 2016, 21:08 Matthias J. Sax <mj...@apache.org> wrote: > 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 > >
