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)
