You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@systemds.apache.org by se...@apache.org on 2022/01/28 17:40:01 UTC
[systemds] branch main updated: [MINOR] Edit FederatedWorker Log
This is an automated email from the ASF dual-hosted git repository.
sebwrede pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/systemds.git
The following commit(s) were added to refs/heads/main by this push:
new fc2b8d8 [MINOR] Edit FederatedWorker Log
fc2b8d8 is described below
commit fc2b8d88077dfd5bf7aadb0ee948cefb315b5afe
Author: sebwrede <sw...@know-center.at>
AuthorDate: Fri Jan 28 18:35:29 2022 +0100
[MINOR] Edit FederatedWorker Log
---
.../sysds/runtime/controlprogram/federated/FederatedWorker.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederatedWorker.java b/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederatedWorker.java
index 4090684..ef94dfe 100644
--- a/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederatedWorker.java
+++ b/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederatedWorker.java
@@ -95,10 +95,11 @@ public class FederatedWorker {
f.channel().closeFuture().sync();
}
catch(Exception e) {
- log.error("Federated worker interrupted");
- log.error(e.getMessage());
- if ( _debug )
+ log.info("Federated worker interrupted");
+ if ( _debug ){
+ log.error(e.getMessage());
e.printStackTrace();
+ }
}
finally {
log.info("Federated Worker Shutting down.");