| commit | ff40ed0b4d5dc2ece79d5826e28618669b6d28a5 | [log] [tgz] |
|---|---|---|
| author | Kostas Kloudas <kkloudas@gmail.com> | Fri Oct 09 14:49:56 2020 +0200 |
| committer | MartijnVisser <martijn@2symbols.com> | Mon Apr 04 15:45:43 2022 +0200 |
| tree | 459c1069f20b5ee41b5ce5d1ff0c5c5b1979a119 | |
| parent | 7903a883ae752c36166ee4a6f5f120ccde3c4fb6 [diff] |
[hotfix] Make Transformation.getTransitivePredecessors() return a list
diff --git a/flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSinkFactoryTest.java b/flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSinkFactoryTest.java index 582a1d8..29e9d49 100644 --- a/flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSinkFactoryTest.java +++ b/flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSinkFactoryTest.java
@@ -47,7 +47,6 @@ import org.elasticsearch.common.xcontent.XContentType; import org.junit.Test; -import java.util.Collection; import java.util.Collections; import java.util.List; import java.util.Map; @@ -214,7 +213,7 @@ } @Override - public Collection<Transformation<?>> getTransitivePredecessors() { + public List<Transformation<?>> getTransitivePredecessors() { return null; }
diff --git a/flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSinkFactoryTest.java b/flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSinkFactoryTest.java index b77d103..099d6ef 100644 --- a/flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSinkFactoryTest.java +++ b/flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSinkFactoryTest.java
@@ -46,7 +46,6 @@ import org.elasticsearch.common.xcontent.XContentType; import org.junit.Test; -import java.util.Collection; import java.util.Collections; import java.util.List; import java.util.Map; @@ -212,7 +211,7 @@ } @Override - public Collection<Transformation<?>> getTransitivePredecessors() { + public List<Transformation<?>> getTransitivePredecessors() { return null; }