[SYSTEMML-827] Fix parfor debug plan output (degree of par special hops) Project: http://git-wip-us.apache.org/repos/asf/incubator-systemml/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-systemml/commit/084afea4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-systemml/tree/084afea4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-systemml/diff/084afea4
Branch: refs/heads/master Commit: 084afea4c14718d2738edcc0c42f15cae681ecd6 Parents: f85cf16 Author: Matthias Boehm <[email protected]> Authored: Fri Jul 22 22:53:09 2016 -0700 Committer: Matthias Boehm <[email protected]> Committed: Sat Jul 23 14:41:50 2016 -0700 ---------------------------------------------------------------------- .../runtime/controlprogram/parfor/opt/OptimizerRuleBased.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-systemml/blob/084afea4/src/main/java/org/apache/sysml/runtime/controlprogram/parfor/opt/OptimizerRuleBased.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/sysml/runtime/controlprogram/parfor/opt/OptimizerRuleBased.java b/src/main/java/org/apache/sysml/runtime/controlprogram/parfor/opt/OptimizerRuleBased.java index 2821d8f..f5fc9ad 100644 --- a/src/main/java/org/apache/sysml/runtime/controlprogram/parfor/opt/OptimizerRuleBased.java +++ b/src/main/java/org/apache/sysml/runtime/controlprogram/parfor/opt/OptimizerRuleBased.java @@ -1549,6 +1549,12 @@ public class OptimizerRuleBased extends Optimizer //need to recompile SB, if changed constraint recompileSB = true; } + //for all other multi-threaded hops set k=1 to simply debugging + else if( h instanceof MultiThreadedHop ) { + MultiThreadedHop mhop = (MultiThreadedHop) h; + mhop.setMaxNumThreads(1); //set max constraint in hop + c.setK(1); //set optnode k (for explain) + } } else rAssignRemainingParallelism(c, parforK, opsK);
