[
https://issues.apache.org/jira/browse/FLINK-41182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-41182:
--------------------------------------
Assignee: Martijn Visser
> Migrate AutoRescalingITCase and RescalingITCase sources to Source V2
> --------------------------------------------------------------------
>
> Key: FLINK-41182
> URL: https://issues.apache.org/jira/browse/FLINK-41182
> Project: Flink
> Issue Type: Sub-task
> Components: Test Infrastructure
> Reporter: Martijn Visser
> Assignee: Martijn Visser
> Priority: Major
>
> The StateSource family checks list and union operator state redistribution
> inside the source. A
> Source V2 reader cannot hold that state, so the checks move to a downstream
> CheckpointedFunction;
> SubtaskIndexSource itself fits AbstractTestSource. The two classes are near
> copies and go together.
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
