This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch rpc_compression in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e481418e300985fdcc53ea37dc52d3b2fcc9050d Author: YongzaoDan <[email protected]> AuthorDate: Tue Oct 24 10:38:10 2023 +0800 Finish --- .../db/queryengine/execution/exchange/MPPDataExchangeService.java | 4 ++-- .../java/org/apache/iotdb/db/service/DataNodeInternalRPCService.java | 3 +-- .../src/main/java/org/apache/iotdb/db/service/MLNodeRPCService.java | 3 ++- 3 files changed, 5 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..ac6846190b9 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 @@ -26,6 +26,7 @@ import org.apache.iotdb.commons.client.sync.SyncDataNodeMPPDataExchangeServiceCl import org.apache.iotdb.commons.concurrent.IoTDBThreadPoolFactory; import org.apache.iotdb.commons.concurrent.IoTThreadFactory; import org.apache.iotdb.commons.concurrent.ThreadName; +import org.apache.iotdb.commons.conf.CommonDescriptor; import org.apache.iotdb.commons.exception.runtime.RPCServiceException; import org.apache.iotdb.commons.service.ServiceType; import org.apache.iotdb.commons.service.ThriftService; @@ -97,8 +98,7 @@ public class MPPDataExchangeService extends ThriftService implements MPPDataExch config.getRpcMaxConcurrentClientNum(), config.getThriftServerAwaitTimeForStopService(), new MPPDataExchangeServiceThriftHandler(), - // TODO: hard coded compress strategy - false); + CommonDescriptor.getInstance().getConfig().isRpcThriftCompressionEnabled()); } 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..a2aaa476219 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 @@ -20,6 +20,7 @@ package org.apache.iotdb.db.service; import org.apache.iotdb.commons.concurrent.ThreadName; +import org.apache.iotdb.commons.conf.CommonDescriptor; import org.apache.iotdb.commons.exception.runtime.RPCServiceException; import org.apache.iotdb.commons.service.ServiceType; import org.apache.iotdb.commons.service.ThriftService; @@ -63,7 +64,7 @@ public class MLNodeRPCService extends ThriftService implements MLNodeRPCServiceM config.getRpcMaxConcurrentClientNum(), config.getThriftServerAwaitTimeForStopService(), new MLNodeRPCServiceThriftHandler(impl), - false); + CommonDescriptor.getInstance().getConfig().isRpcThriftCompressionEnabled()); } catch (RPCServiceException e) { throw new IllegalAccessException(e.getMessage()); }
