[systemds] branch master updated: [MINOR] Change Process to Thread FederatedWorkerHandlerTest

[ba...@apache.org]

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 4a57b23  [MINOR] Change Process to Thread FederatedWorkerHandlerTest
4a57b23 is described below

commit 4a57b232bb57d18d429422d0f08e79ef63ed6be5
Author: sebwrede <sw...@know-center.at>
AuthorDate: Mon Sep 21 10:15:24 2020 +0200

    [MINOR] Change Process to Thread FederatedWorkerHandlerTest
    
    Closes #1059
---
 .../sysds/test/functions/federated/primitives/FederatedRCBindTest.java  | 1 -
 .../apache/sysds/test/functions/privacy/FederatedWorkerHandlerTest.java | 2 +-
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/test/java/org/apache/sysds/test/functions/federated/primitives/FederatedRCBindTest.java b/src/test/java/org/apache/sysds/test/functions/federated/primitives/FederatedRCBindTest.java
index 8b3b04f..712c041 100644
--- a/src/test/java/org/apache/sysds/test/functions/federated/primitives/FederatedRCBindTest.java
+++ b/src/test/java/org/apache/sysds/test/functions/federated/primitives/FederatedRCBindTest.java
@@ -28,7 +28,6 @@ import org.apache.sysds.runtime.meta.MatrixCharacteristics;
 import org.apache.sysds.test.AutomatedTestBase;
 import org.apache.sysds.test.TestConfiguration;
 import org.apache.sysds.test.TestUtils;
-
 import java.util.Arrays;
 import java.util.Collection;
 
diff --git a/src/test/java/org/apache/sysds/test/functions/privacy/FederatedWorkerHandlerTest.java b/src/test/java/org/apache/sysds/test/functions/privacy/FederatedWorkerHandlerTest.java
index d4f3862..7b18293 100644
--- a/src/test/java/org/apache/sysds/test/functions/privacy/FederatedWorkerHandlerTest.java
+++ b/src/test/java/org/apache/sysds/test/functions/privacy/FederatedWorkerHandlerTest.java
@@ -233,7 +233,7 @@ public class FederatedWorkerHandlerTest extends AutomatedTestBase {
 		writeInputMatrixWithMTD("A", A, false, new MatrixCharacteristics(rows, cols, blocksize, rows * cols), new PrivacyConstraint(privacyLevel));
 
 		int port = getRandomAvailablePort();
-		Process t = startLocalFedWorker(port);
+		Thread t = startLocalFedWorkerThread(port);
 
 		// we need the reference file to not be written to hdfs, so we get the correct format
 		rtplatform = Types.ExecMode.SINGLE_NODE;