[FLINK-32694] Migrate ParallelSourceFunction classes to Source V2 API or prepare for removal

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Connectors / Common
• Assignee: Alexander Fedulov
• Reporter: Alexander Fedulov
• Created: 26/Jul/23 20:26
• Updated: 28/Oct/23 13:13

Description

 

• SimpleEndlessSourceWithBloatedState in HeavyDeploymentStressTestProgram (org.apache.flink.deployment)
• StatefulSequenceSource (org.apache.flink.streaming.api.functions.source)   Migration not needed: https://github.com/apache/flink/pull/23611
• ArrowSourceFunction (org.apache.flink.table.runtime.arrow.sources)
• InputFormatSourceFunction (org.apache.flink.streaming.api.functions.source)
• EventsGeneratorSource (org.apache.flink.streaming.examples.statemachine.generator)  resolved in FLINK-32670
• FromSplittableIteratorFunction (org.apache.flink.streaming.api.functions.source)
• DataGeneratorSource (org.apache.flink.streaming.api.functions.source.datagen)
• – Tests:
• MySource in StatefulStreamingJob (org.apache.flink.test)
• RandomLongSource in StickyAllocationAndLocalRecoveryTestJob (org.apache.flink.streaming.tests)
• SequenceGeneratorSource (org.apache.flink.streaming.tests)
• TtlStateUpdateSource (org.apache.flink.streaming.tests)
• StringSourceFunction in NettyShuffleMemoryControlTestProgram (org.apache.flink.streaming.tests)