diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/MainTest.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/MainTest.java index 3071b4e0b4..fbf499eb48 100644 --- a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/MainTest.java +++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/MainTest.java @@ -1,6 +1,5 @@ package org.apache.dolphinscheduler.remote.rpc; -import org.apache.dolphinscheduler.remote.rpc.client.IRpcClient; import org.apache.dolphinscheduler.remote.rpc.client.RpcClient; /** diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/filter/directory/Directory.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/directory/Directory.java similarity index 95% rename from dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/filter/directory/Directory.java rename to dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/directory/Directory.java index c090e0ebb3..7c4907d6dc 100644 --- a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/filter/directory/Directory.java +++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/directory/Directory.java @@ -1,4 +1,4 @@ -package org.apache.dolphinscheduler.remote.rpc.filter.directory; +package org.apache.dolphinscheduler.remote.rpc.directory; import org.apache.dolphinscheduler.remote.rpc.filter.SelectorFilter; diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/filter/SelectorFilter.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/filter/SelectorFilter.java index dea5a0f652..30aa32e9f2 100644 --- a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/filter/SelectorFilter.java +++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/filter/SelectorFilter.java @@ -3,11 +3,10 @@ package org.apache.dolphinscheduler.remote.rpc.filter; import org.apache.dolphinscheduler.remote.rpc.Invoker; import org.apache.dolphinscheduler.remote.rpc.common.RpcRequest; import org.apache.dolphinscheduler.remote.rpc.common.RpcResponse; -import org.apache.dolphinscheduler.remote.rpc.filter.directory.Directory; import org.apache.dolphinscheduler.remote.rpc.selector.RandomSelector; import org.apache.dolphinscheduler.remote.utils.Host; +im -import java.nio.channels.Selector; import java.util.ArrayList; import java.util.List;