[ https://issues.apache.org/jira/browse/FLINK-28046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17743650#comment-17743650 ]
Leonard Xu commented on FLINK-28046: ------------------------------------ The java document[1] of SourceFuntion said: "@deprecated ...., NOTE: All sub-tasks from FLINK-28045 must be closed before this API can be completely removed." , as FLINK-28045 has too many subtasks did not been finished, *+1* to revert the change. The correct way to deprecate SourceFuntion is resolve all subtasks for FLINK-28045 firstly and then deprecated it. [1]https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java#L97 > Annotate SourceFunction as deprecated > ------------------------------------- > > Key: FLINK-28046 > URL: https://issues.apache.org/jira/browse/FLINK-28046 > Project: Flink > Issue Type: Sub-task > Components: API / DataStream > Affects Versions: 1.15.3 > Reporter: Alexander Fedulov > Assignee: Alexander Fedulov > Priority: Major > Labels: pull-request-available, stale-assigned > Fix For: 1.18.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)