(flink) branch master updated: [FLINK-36491][table-common] Remove the deprecated method in DataStreamSinkProvider (#25564)

[ron]

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 73afb6e636c [FLINK-36491][table-common] Remove the deprecated method 
in DataStreamSinkProvider (#25564)
73afb6e636c is described below

commit 73afb6e636cfaa2788c8f66a93c1abb86bf8761b
Author: Gantigmaa Selenge <39860586+tinasele...@users.noreply.github.com>
AuthorDate: Thu Jan 2 06:01:33 2025 +0000

    [FLINK-36491][table-common] Remove the deprecated method in 
DataStreamSinkProvider (#25564)
    
    Signed-off-by: Gantigmaa Selenge <tina.sele...@gmail.com>
---
 .../table/connector/sink/DataStreamSinkProvider.java | 20 ++------------------
 1 file changed, 2 insertions(+), 18 deletions(-)

diff --git 
a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/DataStreamSinkProvider.java
 
b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/DataStreamSinkProvider.java
index 7cb36e3d32a..f850aeb50cf 100644
--- 
a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/DataStreamSinkProvider.java
+++ 
b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/DataStreamSinkProvider.java
@@ -55,24 +55,8 @@ public interface DataStreamSinkProvider
      *
      * @see SingleOutputStreamOperator#uid(String)
      */
-    default DataStreamSink<?> consumeDataStream(
-            ProviderContext providerContext, DataStream<RowData> dataStream) {
-        return consumeDataStream(dataStream);
-    }
-
-    /**
-     * Consumes the given Java {@link DataStream} and returns the sink 
transformation {@link
-     * DataStreamSink}.
-     *
-     * @deprecated Use {@link 
DataStreamSinkProvider#consumeDataStream(ProviderContext, DataStream)}
-     *     and correctly set a unique identifier for each data stream 
transformation.
-     */
-    @Deprecated
-    default DataStreamSink<?> consumeDataStream(DataStream<RowData> 
dataStream) {
-        throw new UnsupportedOperationException(
-                "This method is deprecated. "
-                        + "Use consumeDataStream(ProviderContext, 
DataStream<RowData>) instead");
-    }
+    DataStreamSink<?> consumeDataStream(
+            ProviderContext providerContext, DataStream<RowData> dataStream);
 
     /**
      * {@inheritDoc}