This is an automated email from the ASF dual-hosted git repository.
guoweijie 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 07bf511a32b [FLINK-28046][connectors] Mark SourceFunction interface as
@deprecated
07bf511a32b is described below
commit 07bf511a32b525f94d258daec347cf777b31bebb
Author: Alexander Fedulov <[email protected]>
AuthorDate: Wed Jun 28 11:59:31 2023 +0200
[FLINK-28046][connectors] Mark SourceFunction interface as @deprecated
---
.../apache/flink/streaming/api/functions/source/SourceFunction.java | 4 ++++
1 file changed, 4 insertions(+)
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 70125ae7945..7febf902628 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,7 +94,11 @@ 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 {
