[jira] [Created] (FLINK-2294) Keyed State does not work with DOP=1

["Aljoscha Krettek (JIRA)" <ji...@apache.org>]

Aljoscha Krettek created FLINK-2294:
---------------------------------------

             Summary: Keyed State does not work with DOP=1
                 Key: FLINK-2294
                 URL: https://issues.apache.org/jira/browse/FLINK-2294
             Project: Flink
          Issue Type: Bug
          Components: Streaming
    Affects Versions: 0.10
            Reporter: Aljoscha Krettek
            Priority: Blocker


When changing the DOP from 3 to 1 in StatefulOperatorTest.apiTest() the test fails. The reason seems to be that the element is not properly set when chaining is happening.

Also, requiring this:
{code}
headContext.setNextInput(nextRecord);
streamOperator.processElement(nextRecord);
{code}

to be called seems rather fragile. Why not set the element in {{processElement()}}. This would also make for cleaner encapsulation, since now all outside code must assume that operators have a {{StreamingRuntimeContext}} on which they set the next element.

The state/keyed state machinery seems dangerously undertested.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)