diff --git a/polaris-dependencies/pom.xml b/polaris-dependencies/pom.xml index aa76a3ef8..e0be2f352 100644 --- a/polaris-dependencies/pom.xml +++ b/polaris-dependencies/pom.xml @@ -269,6 +269,13 @@ polaris-test-mock-discovery ${project.version} + + + + com.tencent.polaris + polaris-all + ${project.version} + \ No newline at end of file diff --git a/polaris-plugins/polaris-plugins-connector/connector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/GrpcConnector.java b/polaris-plugins/polaris-plugins-connector/connector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/GrpcConnector.java index ce5904912..869e68223 100644 --- a/polaris-plugins/polaris-plugins-connector/connector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/GrpcConnector.java +++ b/polaris-plugins/polaris-plugins-connector/connector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/GrpcConnector.java @@ -163,7 +163,7 @@ private void submitServiceHandler(ServiceUpdateTask updateTask, long delayMs) { LOG.info("[ServerConnector]task for service {} has been scheduled builtin", updateTask); buildInExecutor.schedule(updateTask, delayMs, TimeUnit.MILLISECONDS); } else { - LOG.info("[ServerConnector]task for service {} has been scheduled discover", updateTask); + LOG.debug("[ServerConnector]task for service {} has been scheduled discover", updateTask); sendDiscoverExecutor.schedule(updateTask, delayMs, TimeUnit.MILLISECONDS); } } diff --git a/polaris-plugins/polaris-plugins-connector/connector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/ServiceUpdateTask.java b/polaris-plugins/polaris-plugins-connector/connector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/ServiceUpdateTask.java index 6ca4ff445..7fb9d06ef 100644 --- a/polaris-plugins/polaris-plugins-connector/connector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/ServiceUpdateTask.java +++ b/polaris-plugins/polaris-plugins-connector/connector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/ServiceUpdateTask.java @@ -185,6 +185,7 @@ public void addUpdateTaskSet() { if (taskType.compareAndSet(Type.FIRST, Type.LONG_RUNNING)) { targetClusterType.set(ClusterType.SERVICE_DISCOVER_CLUSTER); grpcConnector.addLongRunningTask(this); + LOG.info("[ServerConnector]task for service {} has been scheduled updated", this); } } @@ -199,6 +200,7 @@ public boolean needUpdate() { } long nowMs = System.currentTimeMillis(); return nowMs - lastUpdateTime.get() >= refreshIntervalMs; + } @Override