This is an automated email from the ASF dual-hosted git repository.

zhonghongsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new ece08fd5e44 Rollback scaling it use more than one proxy. (#20069)
ece08fd5e44 is described below

commit ece08fd5e445138b94bee3b51de9b6159af86a72
Author: Xinze Guo <[email protected]>
AuthorDate: Thu Aug 11 11:21:41 2022 +0800

    Rollback scaling it use more than one proxy. (#20069)
---
 .../pipeline/framework/container/compose/DockerComposedContainer.java | 4 ----
 .../integration/data/pipeline/framework/watcher/ScalingWatcher.java   | 3 ---
 2 files changed, 7 deletions(-)

diff --git 
a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/framework/container/compose/DockerComposedContainer.java
 
b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/framework/container/compose/DockerComposedContainer.java
index 5cf80fcb3dc..ea575af8952 100644
--- 
a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/framework/container/compose/DockerComposedContainer.java
+++ 
b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/framework/container/compose/DockerComposedContainer.java
@@ -50,10 +50,6 @@ public final class DockerComposedContainer extends 
BaseComposedContainer {
                 (ShardingSphereProxyClusterContainer) 
AdapterContainerFactory.newInstance("Cluster", "proxy", databaseType, 
storageContainer, "", "scaling");
         proxyClusterContainer.dependsOn(governanceContainer, storageContainer);
         proxyContainer = 
getContainers().registerContainer(proxyClusterContainer);
-        ShardingSphereProxyClusterContainer anotherProxyContainer =
-                (ShardingSphereProxyClusterContainer) 
AdapterContainerFactory.newInstance("Cluster", "proxy", databaseType, 
storageContainer, "", "scaling");
-        anotherProxyContainer.dependsOn(governanceContainer, storageContainer);
-        getContainers().registerContainer(anotherProxyContainer);
     }
     
     @Override
diff --git 
a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/framework/watcher/ScalingWatcher.java
 
b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/framework/watcher/ScalingWatcher.java
index 5d2c200c9e7..59e7f49af11 100644
--- 
a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/framework/watcher/ScalingWatcher.java
+++ 
b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/framework/watcher/ScalingWatcher.java
@@ -76,9 +76,6 @@ public class ScalingWatcher extends TestWatcher {
     
     private void addZookeeperData(final String key, final String parentPath, 
final ClusterPersistRepository zookeeperRepository, final Map<String, String> 
nodeMap) {
         String path = String.join("/", parentPath, key);
-        if (path.endsWith("/config")) {
-            return;
-        }
         String data = zookeeperRepository.get(path);
         nodeMap.put(path, data);
         List<String> childrenKeys = zookeeperRepository.getChildrenKeys(path);

Reply via email to