You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2014/11/17 17:08:40 UTC
[3/3] incubator-flink git commit: Fix flaky test SumMinMaxITCase
Fix flaky test SumMinMaxITCase
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/2d1532f3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/2d1532f3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/2d1532f3
Branch: refs/heads/master
Commit: 2d1532f33e05642477918121f25756f533ffe9c6
Parents: 9c1585e
Author: Stephan Ewen <se...@apache.org>
Authored: Mon Nov 17 16:24:04 2014 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Nov 17 16:24:04 2014 +0100
----------------------------------------------------------------------
.../org/apache/flink/test/javaApiOperators/SumMinMaxITCase.java | 2 --
.../org/apache/flink/api/scala/operators/SumMinMaxITCase.scala | 5 +----
2 files changed, 1 insertion(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/2d1532f3/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/SumMinMaxITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/SumMinMaxITCase.java b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/SumMinMaxITCase.java
index bf92893..61ba722 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/SumMinMaxITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/SumMinMaxITCase.java
@@ -16,10 +16,8 @@
* limitations under the License.
*/
-
package org.apache.flink.test.javaApiOperators;
-
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.tuple.Tuple1;
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/2d1532f3/flink-tests/src/test/scala/org/apache/flink/api/scala/operators/SumMinMaxITCase.scala
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/operators/SumMinMaxITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/operators/SumMinMaxITCase.scala
index 488520e..a838907 100644
--- a/flink-tests/src/test/scala/org/apache/flink/api/scala/operators/SumMinMaxITCase.scala
+++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/operators/SumMinMaxITCase.scala
@@ -15,6 +15,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
+
package org.apache.flink.api.scala.operators
import org.apache.flink.api.java.aggregation.Aggregations
@@ -31,8 +32,6 @@ import scala.collection.mutable
import org.apache.flink.api.scala._
-
-
/**
* These tests are copied from [[AggregateITCase]] replacing calls to aggregate with calls to sum,
* min, and max
@@ -45,8 +44,6 @@ object SumMinMaxProgs {
case 1 =>
// Full aggregate
val env = ExecutionEnvironment.getExecutionEnvironment
- env.setDegreeOfParallelism(10)
- // val ds = CollectionDataSets.get3TupleDataSet(env)
val ds = CollectionDataSets.get3TupleDataSet(env)
val aggregateDs = ds