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 cf5dc8d [MINOR] Fix federated test
cf5dc8d is described below
commit cf5dc8d3b0e0b87b282413d93c4de2e973f887a8
Author: baunsgaard
AuthorDate: Fri Aug 21 17:11:18 2020 +0200
[MINOR] Fix federated test
This commit fixes the test added in
#19b4929b3b23e01c3d62e09875891e4f6cfb6e5b
- fix enabling execution of sum square federated operations.
- fix test name in federated LogRegTest.
- fix asserted federated operations in LogRegTest
---
.../runtime/controlprogram/federated/FederationUtils.java| 2 +-
.../sysds/test/functions/federated/FederatedGLMTest.java | 2 +-
.../sysds/test/functions/federated/FederatedLogRegTest.java | 12 +---
src/test/scripts/functions/federated/FederatedLogRegTest.dml | 2 +-
.../functions/federated/FederatedLogRegTestReference.dml | 2 +-
5 files changed, 9 insertions(+), 11 deletions(-)
diff --git
a/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederationUtils.java
b/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederationUtils.java
index 027c577..faae560 100644
---
a/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederationUtils.java
+++
b/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederationUtils.java
@@ -136,7 +136,7 @@ public class FederationUtils {
}
public static ScalarObject aggScalar(AggregateUnaryOperator aop,
Future[] ffr) {
- if(!(aop.aggOp.increOp.fn instanceof KahanPlus ||
(aop.aggOp.increOp.fn instanceof Builtin &&
+ if(!(aop.aggOp.increOp.fn instanceof KahanFunction ||
(aop.aggOp.increOp.fn instanceof Builtin &&
(((Builtin) aop.aggOp.increOp.fn).getBuiltinCode() ==
BuiltinCode.MIN ||
((Builtin)
aop.aggOp.increOp.fn).getBuiltinCode() == BuiltinCode.MAX {
throw new DMLRuntimeException("Unsupported aggregation
operator: "
diff --git
a/src/test/java/org/apache/sysds/test/functions/federated/FederatedGLMTest.java
b/src/test/java/org/apache/sysds/test/functions/federated/FederatedGLMTest.java
index fe24bc8..009d921 100644
---
a/src/test/java/org/apache/sysds/test/functions/federated/FederatedGLMTest.java
+++
b/src/test/java/org/apache/sysds/test/functions/federated/FederatedGLMTest.java
@@ -99,7 +99,7 @@ public class FederatedGLMTest extends AutomatedTestBase {
TestConfiguration config =
availableTestConfigurations.get(TEST_NAME);
loadTestConfiguration(config);
- setOutputBuffering(false);
+ // setOutputBuffering(false);
// Run reference dml script with normal matrix
fullDMLScriptName = HOME + TEST_NAME + "Reference.dml";
diff --git
a/src/test/java/org/apache/sysds/test/functions/federated/FederatedLogRegTest.java
b/src/test/java/org/apache/sysds/test/functions/federated/FederatedLogRegTest.java
index 5a52bb6..1c07bfc 100644
---
a/src/test/java/org/apache/sysds/test/functions/federated/FederatedLogRegTest.java
+++
b/src/test/java/org/apache/sysds/test/functions/federated/FederatedLogRegTest.java
@@ -40,7 +40,7 @@ public class FederatedLogRegTest extends AutomatedTestBase {
private final static String TEST_DIR = "functions/federated/";
private final static String TEST_NAME = "FederatedLogRegTest";
- private final static String TEST_CLASS_DIR = TEST_DIR +
FederatedGLMTest.class.getSimpleName() + "/";
+ private final static String TEST_CLASS_DIR = TEST_DIR +
FederatedLogRegTest.class.getSimpleName() + "/";
private final static int blocksize = 1024;
@Parameterized.Parameter()
@@ -108,7 +108,7 @@ public class FederatedLogRegTest extends AutomatedTestBase {
// Run actual dml script with federated matrix
fullDMLScriptName = HOME + TEST_NAME + ".dml";
- programArgs = new String[] {"-stats",
+ programArgs = new String[] {"-stats", "30",
"-nvargs", "in_X1=" + TestUtils.federatedAddress(port1,
input("X1")),
"in_X2=" + TestUtils.federatedAddress(port2,
input("X2")), "rows=" + rows, "cols=" + cols,
"in_Y=" + input("Y"), "out=" + output("Z")};
@@ -120,11 +120,9 @@ public class FederatedLogRegTest extends AutomatedTestBase
{
TestUtils.shutdownThreads(t1, t2);
// check for federated operations
- Assert.assertTrue(heavyHittersContainsString("fed_ba+*"));
-
Assert.assertTrue(heavyHittersContainsString("fed_uark+","fed_uarsqk+"));
- Assert.assertTrue(heavyHittersContainsString("fed_uack+"));
-
