You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ro...@apache.org on 2025/01/02 05:57:06 UTC
(flink) branch master updated: [FLINK-36490][table-common] Remove the deprecated method in DataStreamScanProvider (#25563)
This is an automated email from the ASF dual-hosted git repository.
ron 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 0c387396744 [FLINK-36490][table-common] Remove the deprecated method in DataStreamScanProvider (#25563)
0c387396744 is described below
commit 0c3873967442e359ed3ee6b4cd16a5ad3df1ba71
Author: Gantigmaa Selenge <39...@users.noreply.github.com>
AuthorDate: Thu Jan 2 05:56:59 2025 +0000
[FLINK-36490][table-common] Remove the deprecated method in DataStreamScanProvider (#25563)
Signed-off-by: Gantigmaa Selenge <ti...@gmail.com>
---
.../table/connector/source/DataStreamScanProvider.java | 14 ++------------
1 file changed, 2 insertions(+), 12 deletions(-)
diff --git a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/DataStreamScanProvider.java b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/DataStreamScanProvider.java
index a7eb43249d2..c219df1753b 100644
--- a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/DataStreamScanProvider.java
+++ b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/DataStreamScanProvider.java
@@ -51,16 +51,6 @@ public interface DataStreamScanProvider
*
* @see SingleOutputStreamOperator#uid(String)
*/
- default DataStream<RowData> produceDataStream(
- ProviderContext providerContext, StreamExecutionEnvironment execEnv) {
- return produceDataStream(execEnv);
- }
-
- /** Creates a scan Java {@link DataStream} from a {@link StreamExecutionEnvironment}. */
- @Deprecated
- default DataStream<RowData> produceDataStream(StreamExecutionEnvironment execEnv) {
- throw new UnsupportedOperationException(
- "This method is deprecated. "
- + "Use produceDataStream(ProviderContext, StreamExecutionEnvironment) instead");
- }
+ DataStream<RowData> produceDataStream(
+ ProviderContext providerContext, StreamExecutionEnvironment execEnv);
}