flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject flink git commit: [ml] [tests] Force pipelined execution of ALSITCase
Date Thu, 19 Mar 2015 14:48:49 GMT
Repository: flink
Updated Branches:
  refs/heads/master 798e59523 -> dafcd4ee4


[ml] [tests] Force pipelined execution of ALSITCase

This a temporary workaround to force pipelined execution of this test. The
default execution mode currently leads to a deadlock.


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

Branch: refs/heads/master
Commit: dafcd4ee449d2d684e404024af13b31289c2de9f
Parents: 798e595
Author: Ufuk Celebi <uce@apache.org>
Authored: Thu Mar 19 15:24:01 2015 +0100
Committer: Ufuk Celebi <uce@apache.org>
Committed: Thu Mar 19 15:48:08 2015 +0100

----------------------------------------------------------------------
 .../scala/org/apache/flink/ml/recommendation/ALSITCase.scala    | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/dafcd4ee/flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/recommendation/ALSITCase.scala
----------------------------------------------------------------------
diff --git a/flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/recommendation/ALSITCase.scala
b/flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/recommendation/ALSITCase.scala
index f2c52d3..691bca4 100644
--- a/flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/recommendation/ALSITCase.scala
+++ b/flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/recommendation/ALSITCase.scala
@@ -18,6 +18,7 @@
 
 package org.apache.flink.ml.recommendation
 
+import org.apache.flink.api.common.ExecutionMode
 import org.apache.flink.api.scala.ExecutionEnvironment
 import org.apache.flink.client.CliFrontendTestUtils
 import org.junit.{BeforeClass, Test}
@@ -33,6 +34,10 @@ class ALSITCase extends ShouldMatchers {
 
     val env = ExecutionEnvironment.getExecutionEnvironment
 
+    // This a temporary workaround to force pipelined execution of this test. The default
execution
+    // leads to a deadlock.
+    env.getConfig.setExecutionMode(ExecutionMode.PIPELINED_FORCED)
+
     env.setDegreeOfParallelism(2)
 
     val als = ALS()


Mime
View raw message