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 <[email protected]> Authored: Thu Mar 19 15:24:01 2015 +0100 Committer: Ufuk Celebi <[email protected]> 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()
