This is an automated email from the ASF dual-hosted git repository.
JackieTien97 pushed a change to branch ty/chinese
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a73dafebe74 fix: complete i18n cleanup for node-commons and datanode
modules
add a6e717f624b Clean up dead RPC thread config and use node-specific
selectorNum (#17551)
add b338c840886 resolve conflicts
add c0728d04974 fix compile
add 65dc8c890eb change more
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 17 +-
.../iotdb/it/env/cluster/config/MppBaseConfig.java | 2 +
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 16 +-
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 16 +-
.../subscription/i18n/SubscriptionMessages.java | 8 +
.../subscription/i18n/SubscriptionMessages.java | 8 +
.../base/AbstractSubscriptionConsumer.java | 8 +-
.../async/AsyncAINodeHeartbeatClientPool.java | 4 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 4 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 4 +-
.../CnToCnInternalServiceAsyncRequestManager.java | 8 +-
.../CnToDnInternalServiceAsyncRequestManager.java | 5 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 28 +++
.../confignode/conf/ConfigNodeDescriptor.java | 18 ++
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 15 ++
.../iotdb/db/i18n/DataNodeQueryMessages.java | 194 +++++++++++++++
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 76 ++++++
.../iotdb/db/i18n/StorageEngineMessages.java | 11 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 15 ++
.../iotdb/db/i18n/DataNodeQueryMessages.java | 194 +++++++++++++++
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 76 ++++++
.../iotdb/db/i18n/StorageEngineMessages.java | 11 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 32 +--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 36 ++-
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 1 +
.../websocket/WebSocketConnectorServer.java | 23 +-
.../protocol/client/DataNodeClientPoolFactory.java | 28 ---
.../DnToCnInternalServiceAsyncRequestManager.java | 5 +
...DataNodeExternalServiceAsyncRequestManager.java | 10 +-
.../client/dn/DataNodeIntraHeartbeatManager.java | 5 +
.../dn/DataNodeMPPServiceAsyncRequestManager.java | 10 +-
.../DnToDnInternalServiceAsyncRequestManager.java | 5 +
.../execution/exchange/MPPDataExchangeManager.java | 78 +++---
.../execution/exchange/SharedTsBlockQueue.java | 6 +-
.../execution/exchange/sink/LocalSinkChannel.java | 14 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 8 +-
.../execution/exchange/sink/SinkChannel.java | 16 +-
.../exchange/source/LocalSourceHandle.java | 16 +-
.../execution/exchange/source/SourceHandle.java | 20 +-
.../fragment/FragmentInstanceExecution.java | 23 +-
.../fragment/FragmentInstanceStateMachine.java | 3 +-
.../execution/operator/source/SeriesScanUtil.java | 8 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 21 +-
.../queryengine/plan/execution/QueryExecution.java | 8 +-
.../config/executor/ClusterConfigTaskExecutor.java | 46 ++--
.../queryengine/plan/planner/TreeModelPlanner.java | 3 -
.../plan/planner/plan/node/write/ObjectNode.java | 3 +-
.../fetcher/TableDeviceSchemaValidator.java | 3 +-
.../logfile/FakeCRC32Deserializer.java | 2 +-
.../schemaregion/logfile/SchemaLogReader.java | 10 +-
.../visitor/SchemaRegionPlanDeserializer.java | 16 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 17 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 4 +-
.../mtree/impl/pbtree/flush/Scheduler.java | 4 +-
.../db/schemaengine/table/DataNodeTableCache.java | 42 ++--
.../template/ClusterTemplateManager.java | 2 +-
.../dataregion/read/control/QueryFileManager.java | 17 +-
.../dataregion/snapshot/SnapshotTaker.java | 26 +-
.../TsFileResourcePipeStatisticsSetTool.java | 36 +--
.../apache/iotdb/metrics/i18n/MetricsMessages.java | 32 +++
.../apache/iotdb/metrics/i18n/MetricsMessages.java | 30 +++
.../metricsets/disk/LinuxDiskMetricsManager.java | 11 +-
.../metricsets/disk/WindowsDiskMetricsManager.java | 15 +-
.../metricsets/net/LinuxNetMetricManager.java | 6 +-
.../conf/iotdb-system.properties.template | 27 ++-
.../apache/iotdb/commons/i18n/AuthMessages.java | 2 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 12 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 141 +++++++++++
.../apache/iotdb/commons/i18n/UtilMessages.java | 6 +
.../apache/iotdb/commons/i18n/AuthMessages.java | 2 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 12 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 136 +++++++++++
.../apache/iotdb/commons/i18n/UtilMessages.java | 6 +
.../commons/auth/authorizer/BasicAuthorizer.java | 2 +-
.../commons/binaryallocator/BinaryAllocator.java | 9 +-
.../binaryallocator/autoreleaser/Releaser.java | 6 +-
.../commons/binaryallocator/evictor/Evictor.java | 5 +-
.../iotdb/commons/client/ClientPoolFactory.java | 58 ++++-
.../client/property/ClientPoolProperty.java | 16 +-
.../client/property/ThriftClientProperty.java | 5 +-
.../client/request/AsyncRequestManager.java | 6 +-
...nfigNodeInternalServiceAsyncRequestManager.java | 10 +-
.../DataNodeInternalServiceRequestManager.java | 10 +-
.../DataNodeIntraHeartbeatRequestManager.java | 9 +-
.../iotdb/commons/concurrent/ThreadName.java | 2 -
.../apache/iotdb/commons/conf/CommonConfig.java | 15 +-
.../iotdb/commons/conf/CommonDescriptor.java | 36 ++-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 12 +-
.../service/PipePluginExecutableManager.java | 8 +-
.../runtime/AbstractPipePeriodicalJobExecutor.java | 9 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 13 +-
.../task/connection/BlockingPendingQueue.java | 5 +-
.../agent/task/execution/PipeSubtaskExecutor.java | 15 +-
.../task/progress/PipeEventCommitManager.java | 11 +-
.../agent/task/subtask/PipeReportableSubtask.java | 5 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 270 +++++++++++++--------
.../options/PipeInclusionOptions.java | 12 +-
.../queue/ConcurrentIterableLinkedQueue.java | 8 +-
.../pipe/metric/PipeEventCommitMetrics.java | 7 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 5 +-
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 19 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 7 +-
.../resource/ref/PipePhantomReferenceManager.java | 5 +-
.../snapshot/PipeSnapshotResourceManager.java | 6 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 30 +--
.../thrift/common/PipeTransferSliceReqHandler.java | 5 +-
.../pipe/sink/protocol/IoTDBAirGapSink.java | 29 +--
.../commons/pipe/sink/protocol/IoTDBSink.java | 15 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 7 +-
.../subscription/config/SubscriptionConfig.java | 24 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 13 +-
.../iotdb/commons/client/ClientManagerTest.java | 19 +-
112 files changed, 1862 insertions(+), 669 deletions(-)
