Exclude DataSet.rebalance() and DataSet.partitionByHash() methods from ScalaAPICompletenessTest

a775c327 · Fabian Hueske · f97f9ba9 · a775c327
隐藏空白更改
内联并排

Showing with 5 addition and 1 deletion

flink-scala/src/test/scala/org/apache/flink/api/scala/ScalaAPICompletenessTest.scala ...org/apache/flink/api/scala/ScalaAPICompletenessTest.scala +5 -1

未找到文件。
--- a/flink-scala/src/test/scala/org/apache/flink/api/scala/ScalaAPICompletenessTest.scala
+++ b/flink-scala/src/test/scala/org/apache/flink/api/scala/ScalaAPICompletenessTest.scala
@@ -65,7 +65,11 @@ class ScalaAPICompletenessTest {
      "org.apache.flink.api.java.DataSet.minBy",
      "org.apache.flink.api.java.DataSet.maxBy",
      "org.apache.flink.api.java.operators.UnsortedGrouping.minBy",
-      "org.apache.flink.api.java.operators.UnsortedGrouping.maxBy"
+      "org.apache.flink.api.java.operators.UnsortedGrouping.maxBy",
+      
+      // Exclude explicit rebalance and hashPartitionBy for now
+      "org.apache.flink.api.java.DataSet.partitionByHash",
+      "org.apache.flink.api.java.DataSet.rebalance"

    )
    val excludedPatterns = Seq(