Repository: systemml Updated Branches: refs/heads/master 8a51003ec -> 5ed2c30e6
[HOTFIX] Fix multi-threaded broadcast creation indexing issue Project: http://git-wip-us.apache.org/repos/asf/systemml/repo Commit: http://git-wip-us.apache.org/repos/asf/systemml/commit/5ed2c30e Tree: http://git-wip-us.apache.org/repos/asf/systemml/tree/5ed2c30e Diff: http://git-wip-us.apache.org/repos/asf/systemml/diff/5ed2c30e Branch: refs/heads/master Commit: 5ed2c30e645855df66f64d4262c2d04207e783b2 Parents: 8a51003 Author: Matthias Boehm <mboe...@gmail.com> Authored: Mon Apr 9 12:29:53 2018 -0700 Committer: Matthias Boehm <mboe...@gmail.com> Committed: Mon Apr 9 12:29:53 2018 -0700 ---------------------------------------------------------------------- .../sysml/runtime/instructions/spark/data/PartitionedBlock.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/systemml/blob/5ed2c30e/src/main/java/org/apache/sysml/runtime/instructions/spark/data/PartitionedBlock.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/sysml/runtime/instructions/spark/data/PartitionedBlock.java b/src/main/java/org/apache/sysml/runtime/instructions/spark/data/PartitionedBlock.java index 61eb5e9..870d2a2 100644 --- a/src/main/java/org/apache/sysml/runtime/instructions/spark/data/PartitionedBlock.java +++ b/src/main/java/org/apache/sysml/runtime/instructions/spark/data/PartitionedBlock.java @@ -80,7 +80,7 @@ public class PartitionedBlock<T extends CacheBlock> implements Externalizable try { _partBlocks = new CacheBlock[nrblks * ncblks]; Arrays.parallelSetAll(_partBlocks, index -> { - int i = index % nrblks; + int i = index / ncblks; int j = index % ncblks; T tmp = (T) CacheBlockFactory.newInstance(code); return block.slice(i * _brlen, Math.min((i + 1) * _brlen, rlen) - 1,
