Skip to content

Commit f425b39

Browse files
committed
revert minor changes matrix block [skip ci]
1 parent ecf7873 commit f425b39

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

src/main/java/org/apache/sysds/runtime/matrix/data/MatrixBlock.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1424,8 +1424,6 @@ public long recomputeNonZeros(int k) {
14241424
if(k <= 1 || ((long) rlen * clen < 10000) || (sparse && sparseBlock!=null))
14251425
return recomputeNonZeros();
14261426
else if(!sparse && denseBlock!=null){
1427-
if((long) rlen * clen < 10000 || k == 1)
1428-
return recomputeNonZeros();
14291427
final ExecutorService pool = CommonThreadPool.get(k);
14301428
try {
14311429
List<Future<Long>> f = new ArrayList<>();
@@ -1453,10 +1451,6 @@ else if(!sparse && denseBlock!=null){
14531451
nnz += e.get();
14541452
nonZeros = nnz;
14551453

1456-
if(nonZeros < 0)
1457-
throw new DMLRuntimeException("Invalid count of non zero values: " + nonZeros);
1458-
return nonZeros;
1459-
14601454
}
14611455
catch(Exception e) {
14621456
LOG.warn("Failed Parallel non zero count fallback to single thread");

0 commit comments

Comments
 (0)