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)

Reply via email to