[ 
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Alexander Fedulov reassigned FLINK-32693:
-----------------------------------------

    Assignee: Alexander Fedulov

> Cascade deprecation to classes that directly implement SourceFunction
> ---------------------------------------------------------------------
>
>                 Key: FLINK-32693
>                 URL: https://issues.apache.org/jira/browse/FLINK-32693
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Connectors / Common
>            Reporter: Alexander Fedulov
>            Assignee: Alexander Fedulov
>            Priority: Major
>
> * SocketTextStreamFunction (org.apache.flink.streaming.api.functions.source)
>  * FiniteTestSource (org.apache.flink.streaming.util)
>  * FromIteratorFunction (org.apache.flink.streaming.api.functions.source)
>  * Generator in FileSinkProgram (org.apache.flink.connector.file.sink)
>  * RichSourceFunction (org.apache.flink.streaming.api.functions.source)
>  * FileMonitoringFunction (org.apache.flink.streaming.api.functions.source)
>  * FromElementsFunction (org.apache.flink.streaming.api.functions.source)
>  * PeriodicSourceGenerator in PeriodicStreamingJob 
> (org.apache.flink.streaming.tests)
>  * Generator in StreamSQLTestProgram (org.apache.flink.sql.tests)
>  * ParallelSourceFunction (org.apache.flink.streaming.api.functions.source)
>  * ExternallyInducedSource (org.apache.flink.streaming.api.checkpoint)
>  * in addSource() in StreamExecutionEnvironment 
> (org.apache.flink.streaming.api.scala)



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to