diff --git 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 index e1d0186cdcaedaca6f1a756787092dfaf7aa440e..fb4396b2d737be5d5e9a96613e38784f8f54dfd7 100644 --- 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(