[hotfix] Fix compile error in DataStreamV2SinkTransformation

apache · Apr 1, 2024 · d271495 · d271495
1 parent 2876249
commit d271495
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...n/java/org/apache/flink/streaming/api/transformations/DataStreamV2SinkTransformation.java b/...n/java/org/apache/flink/streaming/api/transformations/DataStreamV2SinkTransformation.java
@@ -69,7 +69,7 @@ public void setChainingStrategy(ChainingStrategy strategy) {
     }
 
     @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
@@ -32,7 +32,7 @@ public TestingTransformation(String name, TypeInformation<T> outputType, int par
     }
 
     @Override
-    public List<Transformation<?>> getTransitivePredecessors() {
+    protected List<Transformation<?>> getTransitivePredecessorsInternal() {
         return Collections.emptyList();
     }