Arvid Heise created FLINK-37108:
-----------------------------------
Summary: Source/Sink test suites test invalid recovery
Key: FLINK-37108
URL: https://issues.apache.org/jira/browse/FLINK-37108
Project: Flink
Issue Type: Improvement
Affects Versions: 2.0-preview, 1.19.1, 1.20.0, 2.0.0
Reporter: Arvid Heise
Assignee: Arvid Heise
The source and sink test suites have a couple of tests that take a snapshot and
then recover from it with lower or higher parallelism. However, while taking
the snapshot they use the `–drain` version (advanceToEndOfEventTime=true),
which should only be used when terminating the pipeline for good. In
particular, all operators receive `endInput()` so they should finalize their
state. The tests, however, add more records to the inputs, such that the
`endInput` contract is violated.
The solution is simple: just use advanceToEndOfEventTime=false.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
