Martijn Visser created FLINK-41169:
--------------------------------------
Summary: Migrate streaming runtime ITCases to Source V2
Key: FLINK-41169
URL: https://issues.apache.org/jira/browse/FLINK-41169
Project: Flink
Issue Type: Sub-task
Components: Test Infrastructure
Reporter: Martijn Visser
FinishedSourcesWatermarkITCase, IntervalJoinITCase (its two SourceFunction
helpers are unused),
StreamTaskSelectiveReadingITCase, SessionWindowITCase, GlobalAggregateITCase
(the
GlobalAggregateManager use moves into a rich function) and
BatchShuffleITCaseBase.
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)