From 07bf511a32b525f94d258daec347cf777b31bebb Mon Sep 17 00:00:00 2001
From: Alexander Fedulov <1492164+afedulov@users.noreply.github.com>
Date: Wed, 28 Jun 2023 11:59:31 +0200
Subject: [PATCH] [FLINK-28046][connectors] Mark SourceFunction interface as
 @deprecated

---
 .../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 70125ae79455e..7febf902628fd 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 @@
  * 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 {