This is an automated email from the ASF dual-hosted git repository.

leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 1635a284d75 Revert "[FLINK-28046][connectors] Mark SourceFunction 
interface as @deprecated"
1635a284d75 is described below

commit 1635a284d75570cc8fc834e7b1bfb2d9d8df0c4a
Author: Hang Ruan <[email protected]>
AuthorDate: Wed Jul 19 15:09:02 2023 +0800

    Revert "[FLINK-28046][connectors] Mark SourceFunction interface as 
@deprecated"
    
    This closes #23018 which reverts commit 
07bf511a32b525f94d258daec347cf777b31bebb.
    We need to resolve all subtasks in FLINK-28045 and then deprecated 
SourceFunction interface.
---
 .../apache/flink/streaming/api/functions/source/SourceFunction.java   | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
index 7febf902628..70125ae7945 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
@@ -94,11 +94,7 @@ import java.io.Serializable;
  * SourceContext#emitWatermark(Watermark)}.
  *
  * @param <T> The type of the elements produced by this source.
- * @deprecated This interface will be removed in future versions. Use the new 
{@link
- *     org.apache.flink.api.connector.source.Source} interface instead. NOTE: 
All sub-tasks from
- *     FLINK-28045 must be closed before this API can be completely removed.
  */
-@Deprecated
 @Public
 public interface SourceFunction<T> extends Function, Serializable {
 

Reply via email to