[hotfix] Fix compile error in DataStreamV2SinkTransformation

reswqa · reswqa · commit 5ec8f1557060 · 2024-04-01T15:15:24.000+08:00
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
@@ -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());

Original file line number	Diff line number	Diff line change
`@@ -69,7 +69,7 @@ public void setChainingStrategy(ChainingStrategy strategy) {`
`69`	`69`	`}`
`70`	`70`
`71`	`71`	`@Override`
`72`		`- public List<Transformation<?>> getTransitivePredecessors() {`
	`72`	`+ protected List<Transformation<?>> getTransitivePredecessorsInternal() {`
`73`	`73`	`final List<Transformation<?>> result = Lists.newArrayList();`
`74`	`74`	`result.add(this);`
`75`	`75`	`result.addAll(input.getTransitivePredecessors());`