From fb3d7736917a3458e1ec573cea2695ab7843594f Mon Sep 17 00:00:00 2001 From: liaochuntao Date: Fri, 13 Jan 2023 20:16:11 +0800 Subject: [PATCH] Bugfix discover switch (#262) --- README-zh.md | 2 +- README.md | 2 +- .../polaris/plugins/connector/grpc/SpecStreamClient.java | 3 +++ pom.xml | 2 +- 4 files changed, 6 insertions(+), 3 deletions(-) diff --git a/README-zh.md b/README-zh.md index 8d6bb2a9b..8894a4ec9 100644 --- a/README-zh.md +++ b/README-zh.md @@ -24,7 +24,7 @@ mvn clean install com.tencent.polaris polaris-dependencies - 1.9.1 + 1.9.2 pom import diff --git a/README.md b/README.md index 184bc0765..24eb55bfa 100644 --- a/README.md +++ b/README.md @@ -27,7 +27,7 @@ Modify pom.xml in application root, add dependencyManagement for polaris-java: com.tencent.polaris polaris-dependencies - 1.9.1 + 1.9.2 pom import diff --git a/polaris-plugins/polaris-plugins-connector/connector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/SpecStreamClient.java b/polaris-plugins/polaris-plugins-connector/connector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/SpecStreamClient.java index f8617a2e0..a38371e81 100644 --- a/polaris-plugins/polaris-plugins-connector/connector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/SpecStreamClient.java +++ b/polaris-plugins/polaris-plugins-connector/connector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/SpecStreamClient.java @@ -324,6 +324,9 @@ public boolean checkAvailable(ServiceUpdateTask serviceUpdateTask) { if (isEndStream()) { return false; } + if (!Connection.isAvailableConnection(connection)) { + return false; + } synchronized (clientLock) { if (isEndStream()) { return false; diff --git a/pom.xml b/pom.xml index 8525a17a7..689ae7f61 100644 --- a/pom.xml +++ b/pom.xml @@ -64,7 +64,7 @@ - 1.9.1 + 1.9.2 ${maven.build.timestamp} false