(flink) branch master updated: [hotfix] Prepare StatefulSequenceSource for removal in 2.0

[ma...@apache.org]

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

mapohl 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 329e3c18350 [hotfix] Prepare StatefulSequenceSource for removal in 2.0
329e3c18350 is described below

commit 329e3c183501fe99be37d663b54f1c1e43bab573
Author: Alexander Fedulov <14...@users.noreply.github.com>
AuthorDate: Sat Oct 28 15:07:32 2023 +0200

    [hotfix] Prepare StatefulSequenceSource for removal in 2.0
---
 .../streaming/api/functions/source/StatefulSequenceSource.java      | 3 +++
 .../apache/flink/connector/datagen/table/DataGenTableSource.java    | 6 +-----
 2 files changed, 4 insertions(+), 5 deletions(-)

diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java
index a9f4d1e7023..983f49c7eca 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java
@@ -42,6 +42,9 @@ import java.util.Deque;
  * <p>This strategy guarantees that each element will be emitted exactly-once, but elements will not
  * necessarily be emitted in ascending order, even for the same tasks.
  *
+ * <p>NOTE: this source will be removed together with the deprecated
+ * StreamExecutionEnvironmetn#generateSequence() method.
+ *
  * @deprecated This class is based on the {@link
  *     org.apache.flink.streaming.api.functions.source.SourceFunction} API, which is due to be
  *     removed. Use the new {@link org.apache.flink.api.connector.source.Source} API instead.
diff --git a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenTableSource.java b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenTableSource.java
index f9c1bf4deee..9163c2a63f2 100644
--- a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenTableSource.java
+++ b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenTableSource.java
@@ -21,7 +21,6 @@ package org.apache.flink.connector.datagen.table;
 import org.apache.flink.annotation.Internal;
 import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.connector.datagen.table.types.RowDataGenerator;
-import org.apache.flink.streaming.api.functions.source.StatefulSequenceSource;
 import org.apache.flink.streaming.api.functions.source.datagen.DataGenerator;
 import org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource;
 import org.apache.flink.table.connector.ChangelogMode;
@@ -33,10 +32,7 @@ import org.apache.flink.table.data.RowData;
 import org.apache.flink.table.sources.StreamTableSource;
 import org.apache.flink.table.types.DataType;
 
-/**
- * A {@link StreamTableSource} that emits each number from a given interval exactly once, possibly
- * in parallel. See {@link StatefulSequenceSource}.
- */
+/** A {@link StreamTableSource} that emits generated data rows. */
 @Internal
 public class DataGenTableSource implements ScanTableSource, SupportsLimitPushDown {