You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2022/07/14 09:30:53 UTC

[iotdb] branch add_rpc_compression_in_sync created (now 1ac1772ff1)

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

qiaojialin pushed a change to branch add_rpc_compression_in_sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 1ac1772ff1 enable rpc compression

This branch includes the following new commits:

     new 1ac1772ff1 enable rpc compression

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[iotdb] 01/01: enable rpc compression

Posted by qi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

qiaojialin pushed a commit to branch add_rpc_compression_in_sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 1ac1772ff1d6086be2eec9f2ed0f3e70674ceea0
Author: qiaojialin <64...@qq.com>
AuthorDate: Thu Jul 14 17:30:38 2022 +0800

    enable rpc compression
---
 server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
index 669957515d..04264ceb6b 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
@@ -168,7 +168,8 @@ public class StorageEngine implements IService {
               config.getSecondaryPort(),
               config.getSecondaryUser(),
               config.getSecondaryPassword(),
-              5);
+              5,
+              config.isRpcThriftCompressionEnable());
 
       // create operationSyncDDLProtector and operationSyncDDLLogService
       operationSyncDDLProtector = new OperationSyncDDLProtector(operationSyncsessionPool);