[iotdb] branch master updated: [IOTDB-6203] Remove rpc_thrift_compression_enable hard code (#11370)

[wangchao316]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 34de5255f31 [IOTDB-6203] Remove rpc_thrift_compression_enable hard 
code (#11370)
34de5255f31 is described below

commit 34de5255f314f50c9dc2a2eab20400e76b60b221
Author: Yongzao <yong...@apache.org>
AuthorDate: Tue Oct 24 15:25:13 2023 +0800

    [IOTDB-6203] Remove rpc_thrift_compression_enable hard code (#11370)
    
    [IOTDB-6203] Remove rpc_thrift_compression_enable hard code (#11370)
---
 .../db/queryengine/execution/exchange/MPPDataExchangeService.java      | 3 +--
 .../java/org/apache/iotdb/db/service/DataNodeInternalRPCService.java   | 3 +--
 .../src/main/java/org/apache/iotdb/db/service/MLNodeRPCService.java    | 2 +-
 3 files changed, 3 insertions(+), 5 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeService.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeService.java
index 36f369fbe13..b42e521bfd8 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeService.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeService.java
@@ -97,8 +97,7 @@ public class MPPDataExchangeService extends ThriftService 
implements MPPDataExch
               config.getRpcMaxConcurrentClientNum(),
               config.getThriftServerAwaitTimeForStopService(),
               new MPPDataExchangeServiceThriftHandler(),
-              // TODO: hard coded compress strategy
-              false);
+              config.isRpcThriftCompressionEnable());
     } catch (RPCServiceException e) {
       throw new IllegalAccessException(e.getMessage());
     }
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/DataNodeInternalRPCService.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/DataNodeInternalRPCService.java
index c1eab0b91da..416dde14982 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/DataNodeInternalRPCService.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/DataNodeInternalRPCService.java
@@ -67,8 +67,7 @@ public class DataNodeInternalRPCService extends ThriftService
               config.getRpcMaxConcurrentClientNum(),
               config.getThriftServerAwaitTimeForStopService(),
               new InternalServiceThriftHandler(),
-              // TODO: hard coded compress strategy
-              false);
+              config.isRpcThriftCompressionEnable());
     } catch (RPCServiceException e) {
       throw new IllegalAccessException(e.getMessage());
     }
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/MLNodeRPCService.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/MLNodeRPCService.java
index 959d55c8f48..7f4300d7a53 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/MLNodeRPCService.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/MLNodeRPCService.java
@@ -63,7 +63,7 @@ public class MLNodeRPCService extends ThriftService 
implements MLNodeRPCServiceM
               config.getRpcMaxConcurrentClientNum(),
               config.getThriftServerAwaitTimeForStopService(),
               new MLNodeRPCServiceThriftHandler(impl),
-              false);
+              config.isRpcThriftCompressionEnable());
     } catch (RPCServiceException e) {
       throw new IllegalAccessException(e.getMessage());
     }