[shardingsphere] branch master updated: set maxInboundMessageSize of etcd client to 32MB (#14291)

[zhangliang]

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

zhangliang 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 d6bff2e  set maxInboundMessageSize of etcd client to 32MB (#14291)
d6bff2e is described below

commit d6bff2eefb34704279c4906ba46465f1872bafac
Author: roodkcab <chenshuo...@gmail.com>
AuthorDate: Sat Dec 25 21:45:32 2021 +0800

    set maxInboundMessageSize of etcd client to 32MB (#14291)
---
 .../shardingsphere/mode/repository/cluster/etcd/EtcdRepository.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-repository/shardingsphere-cluster-mode-repository-provider/shardingsphere-cluster-mode-repository-etcd/src/main/java/org/apache/shardingsphere/mode/repository/cluster/etcd/EtcdRepository.java
 
b/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-repository/shardingsphere-cluster-mode-repository-provider/shardingsphere-cluster-mo
 [...]
index 0a839d0..7b84467 100644
--- 
a/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-repository/shardingsphere-cluster-mode-repository-provider/shardingsphere-cluster-mode-repository-etcd/src/main/java/org/apache/shardingsphere/mode/repository/cluster/etcd/EtcdRepository.java
+++ 
b/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-repository/shardingsphere-cluster-mode-repository-provider/shardingsphere-cluster-mode-repository-etcd/src/main/java/org/apache/shardingsphere/mode/repository/cluster/etcd/EtcdRepository.java
@@ -65,8 +65,10 @@ public final class EtcdRepository implements 
ClusterPersistRepository {
     @Override
     public void init(final ClusterPersistRepositoryConfiguration config) {
         etcdProperties = new EtcdProperties(props);
-        client = Client.builder().endpoints(
-                
Util.toURIs(Splitter.on(",").trimResults().splitToList(config.getServerLists()))).namespace(ByteSequence.from(config.getNamespace(),
 StandardCharsets.UTF_8)).build();
+        client = 
Client.builder().endpoints(Util.toURIs(Splitter.on(",").trimResults().splitToList(config.getServerLists())))
+                .namespace(ByteSequence.from(config.getNamespace(), 
StandardCharsets.UTF_8))
+                .maxInboundMessageSize((int) 32e9)
+                .build();
     }
     
     @SneakyThrows({InterruptedException.class, ExecutionException.class})