From a775c327ffb932e73826d4cfe4005cc62c58d4b6 Mon Sep 17 00:00:00 2001 From: Fabian Hueske Date: Tue, 23 Sep 2014 18:49:38 +0200 Subject: [PATCH] Exclude DataSet.rebalance() and DataSet.partitionByHash() methods from ScalaAPICompletenessTest --- .../apache/flink/api/scala/ScalaAPICompletenessTest.scala | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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 e1d0186cdca..fb4396b2d73 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( -- GitLab