flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Streaming Iterations, no headOperator ?
Date Sat, 02 Jan 2016 20:18:03 GMT
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 <mjsax@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
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message