This is an automated email from the ASF dual-hosted git repository.

baunsgaard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/systemds.git


The following commit(s) were added to refs/heads/master by this push:
     new 60d41a8  [MINOR] Fix read non zeros from mdt file
60d41a8 is described below

commit 60d41a8a774f868812b8ca7cae5c987afc789b1b
Author: baunsgaard <[email protected]>
AuthorDate: Tue Aug 25 20:58:56 2020 +0200

    [MINOR] Fix read non zeros from mdt file
    
    In federated workers, the IO time was off, compared to local execution.
    This was due to a missing reading of the NonZeros.
    This commit adds this 1 LINE!
---
 .../sysds/runtime/controlprogram/federated/FederatedWorkerHandler.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederatedWorkerHandler.java
 
b/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederatedWorkerHandler.java
index b09b75d..fb8c494 100644
--- 
a/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederatedWorkerHandler.java
+++ 
b/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederatedWorkerHandler.java
@@ -195,6 +195,7 @@ public class FederatedWorkerHandler extends 
ChannelInboundHandlerAdapter {
                                                        new 
FederatedWorkerHandlerException("Could not parse metadata file"));
                                        
mc.setRows(mtd.getLong(DataExpression.READROWPARAM));
                                        
mc.setCols(mtd.getLong(DataExpression.READCOLPARAM));
+                                       
mc.setNonZeros(mtd.getLong(DataExpression.READNNZPARAM));
                                        cd = (CacheableData<?>) 
PrivacyPropagator.parseAndSetPrivacyConstraint(cd, mtd);
                                        fmt = 
FileFormat.safeValueOf(mtd.getString(DataExpression.FORMAT_TYPE));
                                }

Reply via email to