[
https://issues.apache.org/jira/browse/FLINK-41166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-41166:
--------------------------------------
Assignee: Martijn Visser
> Migrate SavepointITCase sources to Source V2
> --------------------------------------------
>
> Key: FLINK-41166
> URL: https://issues.apache.org/jira/browse/FLINK-41166
> Project: Flink
> Issue Type: Sub-task
> Components: Test Infrastructure
> Reporter: Martijn Visser
> Assignee: Martijn Visser
> Priority: Major
>
> InfiniteTestSource, CancelFailingInfiniteTestSource,
> SnapshotFailingInfiniteTestSource and
> IntegerStreamSource. The failure hooks map onto a TestSourceReader's
> snapshotState and
> notifyCheckpointComplete. testStopSavepointWithBoundedInput is the only test
> that
> stop-with-savepoint without drain does not call endInput; it moves to a V2
> source. The unused
> suspendAll, cancelAllAndAwait and resetForTest helpers can go.
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
