(flink) branch master updated: [hotfix] Fix compile error in DataStreamV2SinkTransformation

[guoweijie]

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 d271495c5be [hotfix] Fix compile error in 
DataStreamV2SinkTransformation
d271495c5be is described below

commit d271495c5be34f4e4a518207ca7716f4e8907e5f
Author: Weijie Guo <res...@163.com>
AuthorDate: Mon Apr 1 15:15:24 2024 +0800

    [hotfix] Fix compile error in DataStreamV2SinkTransformation
---
 .../streaming/api/transformations/DataStreamV2SinkTransformation.java   | 2 +-
 .../java/org/apache/flink/datastream/impl/TestingTransformation.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-datastream/src/main/java/org/apache/flink/streaming/api/transformations/DataStreamV2SinkTransformation.java
 
b/flink-datastream/src/main/java/org/apache/flink/streaming/api/transformations/DataStreamV2SinkTransformation.java
index ae702d9e259..17cd912f17e 100644
--- 
a/flink-datastream/src/main/java/org/apache/flink/streaming/api/transformations/DataStreamV2SinkTransformation.java
+++ 
b/flink-datastream/src/main/java/org/apache/flink/streaming/api/transformations/DataStreamV2SinkTransformation.java
@@ -69,7 +69,7 @@ public class DataStreamV2SinkTransformation<InputT, OutputT>
     }
 
     @Override
-    public List<Transformation<?>> getTransitivePredecessors() {
+    protected List<Transformation<?>> getTransitivePredecessorsInternal() {
         final List<Transformation<?>> result = Lists.newArrayList();
         result.add(this);
         result.addAll(input.getTransitivePredecessors());
diff --git 
a/flink-datastream/src/test/java/org/apache/flink/datastream/impl/TestingTransformation.java
 
b/flink-datastream/src/test/java/org/apache/flink/datastream/impl/TestingTransformation.java
index 20b596a8631..8c1f1370ad0 100644
--- 
a/flink-datastream/src/test/java/org/apache/flink/datastream/impl/TestingTransformation.java
+++ 
b/flink-datastream/src/test/java/org/apache/flink/datastream/impl/TestingTransformation.java
@@ -32,7 +32,7 @@ public class TestingTransformation<T> extends 
Transformation<T> {
     }
 
     @Override
-    public List<Transformation<?>> getTransitivePredecessors() {
+    protected List<Transformation<?>> getTransitivePredecessorsInternal() {
         return Collections.emptyList();
     }