From eeb12c58c43dedc3b687b9664644f6eadf0c2760 Mon Sep 17 00:00:00 2001 From: taegeonum Date: Fri, 7 Jun 2019 16:26:59 +0900 Subject: [PATCH 1/2] [NEMO-391] Set GrpcMessageEnvironment as a default implementation --- .../apache/nemo/runtime/common/message/MessageEnvironment.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageEnvironment.java b/runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageEnvironment.java index 7e4067b3eb..18da37d1b0 100644 --- a/runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageEnvironment.java +++ b/runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageEnvironment.java @@ -18,6 +18,7 @@ */ package org.apache.nemo.runtime.common.message; +import org.apache.nemo.runtime.common.message.grpc.GrpcMessageEnvironment; import org.apache.nemo.runtime.common.message.ncs.NcsMessageEnvironment; import org.apache.reef.tang.annotations.DefaultImplementation; @@ -27,7 +28,7 @@ * Set up {@link MessageListener}s to handle incoming messages on this node, and connect to remote nodes and return * {@link MessageSender}s to send message to them. */ -@DefaultImplementation(NcsMessageEnvironment.class) +@DefaultImplementation(GrpcMessageEnvironment.class) public interface MessageEnvironment { // The ID of the master used for distinguish the sender or receiver. From 6663874beeba1e8441605673c6f9df68de4fa6db Mon Sep 17 00:00:00 2001 From: taegeonum Date: Fri, 7 Jun 2019 16:39:29 +0900 Subject: [PATCH 2/2] rm import --- .../apache/nemo/runtime/common/message/MessageEnvironment.java | 1 - 1 file changed, 1 deletion(-) diff --git a/runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageEnvironment.java b/runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageEnvironment.java index 18da37d1b0..5fc26a294c 100644 --- a/runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageEnvironment.java +++ b/runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageEnvironment.java @@ -19,7 +19,6 @@ package org.apache.nemo.runtime.common.message; import org.apache.nemo.runtime.common.message.grpc.GrpcMessageEnvironment; -import org.apache.nemo.runtime.common.message.ncs.NcsMessageEnvironment; import org.apache.reef.tang.annotations.DefaultImplementation; import java.util.concurrent.Future;