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 {