Alexander Fedulov created FLINK-32694:
-----------------------------------------
Summary: Cascade deprecation to classes that implement
ParallelSourceFunction
Key: FLINK-32694
URL: https://issues.apache.org/jira/browse/FLINK-32694
Project: Flink
Issue Type: Sub-task
Components: Connectors / Common
Reporter: Alexander Fedulov
* RichParallelSourceFunction (org.apache.flink.streaming.api.functions.source)
* 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)
* SimpleEndlessSourceWithBloatedState in HeavyDeploymentStressTestProgram
(org.apache.flink.deployment)
* StringSourceFunction in NettyShuffleMemoryControlTestProgram
(org.apache.flink.streaming.tests)
* 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)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
