Skip to content

Commit d271495

Browse files
committed
[hotfix] Fix compile error in DataStreamV2SinkTransformation
1 parent 2876249 commit d271495

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

flink-datastream/src/main/java/org/apache/flink/streaming/api/transformations/DataStreamV2SinkTransformation.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ public void setChainingStrategy(ChainingStrategy strategy) {
6969
}
7070

7171
@Override
72-
public List<Transformation<?>> getTransitivePredecessors() {
72+
protected List<Transformation<?>> getTransitivePredecessorsInternal() {
7373
final List<Transformation<?>> result = Lists.newArrayList();
7474
result.add(this);
7575
result.addAll(input.getTransitivePredecessors());

flink-datastream/src/test/java/org/apache/flink/datastream/impl/TestingTransformation.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ public TestingTransformation(String name, TypeInformation<T> outputType, int par
3232
}
3333

3434
@Override
35-
public List<Transformation<?>> getTransitivePredecessors() {
35+
protected List<Transformation<?>> getTransitivePredecessorsInternal() {
3636
return Collections.emptyList();
3737
}
3838

0 commit comments

Comments
 (0)