You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2014/09/24 11:33:44 UTC

[2/3] git commit: Exclude DataSet.rebalance() and DataSet.partitionByHash() methods from ScalaAPICompletenessTest

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


Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/a775c327
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/a775c327
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/a775c327

Branch: refs/heads/master
Commit: a775c327ffb932e73826d4cfe4005cc62c58d4b6
Parents: f97f9ba
Author: Fabian Hueske <fh...@apache.org>
Authored: Tue Sep 23 18:49:38 2014 +0200
Committer: Fabian Hueske <fh...@apache.org>
Committed: Wed Sep 24 10:44:23 2014 +0200

----------------------------------------------------------------------
 .../org/apache/flink/api/scala/ScalaAPICompletenessTest.scala  | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/a775c327/flink-scala/src/test/scala/org/apache/flink/api/scala/ScalaAPICompletenessTest.scala
----------------------------------------------------------------------
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 e1d0186..fb4396b 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(