[ https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alexander Fedulov updated FLINK-32694: -------------------------------------- Summary: Migrate classes that implement ParallelSourceFunction to Source V2 API (was: Cascade deprecation to classes that implement ParallelSourceFunction) > Migrate classes that implement ParallelSourceFunction to Source V2 API > ---------------------------------------------------------------------- > > Key: FLINK-32694 > URL: https://issues.apache.org/jira/browse/FLINK-32694 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Common > Reporter: Alexander Fedulov > Assignee: Alexander Fedulov > Priority: Major > > > * SimpleEndlessSourceWithBloatedState in HeavyDeploymentStressTestProgram > (org.apache.flink.deployment) > * StatefulSequenceSource (org.apache.flink.streaming.api.functions.source) > * ArrowSourceFunction (org.apache.flink.table.runtime.arrow.sources) > * InputFormatSourceFunction (org.apache.flink.streaming.api.functions.source) > * EventsGeneratorSource > (org.apache.flink.streaming.examples.statemachine.generator) > * 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) -- This message was sent by Atlassian Jira (v8.20.10#820010)