[
https://issues.apache.org/jira/browse/FLINK-41163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-41163:
--------------------------------------
Assignee: Martijn Visser
> Migrate KeyedStateCheckpointingITCase and CoStreamCheckpointingITCase to
> DataGeneratorSource
> --------------------------------------------------------------------------------------------
>
> Key: FLINK-41163
> URL: https://issues.apache.org/jira/browse/FLINK-41163
> Project: Flink
> Issue Type: Sub-task
> Components: Test Infrastructure
> Reporter: Martijn Visser
> Assignee: Martijn Visser
> Priority: Major
>
> Both sources hold back until the first (or second) checkpoint and then run
> freely.
> RateLimiterStrategy.perCheckpoint gates every checkpoint cycle instead, so
> recordsPerCheckpoint
> has to be sized to keep the runtime bounded. DataGeneratorSource hands out
> splits first-come, so
> keys derive from the generated value, not the subtask index.
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
