You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@systemml.apache.org by mb...@apache.org on 2018/04/09 19:30:07 UTC
systemml git commit: [HOTFIX] Fix multi-threaded broadcast creation
indexing issue
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 <mb...@gmail.com>
Authored: Mon Apr 9 12:29:53 2018 -0700
Committer: Matthias Boehm <mb...@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,