This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch tsbs/iot in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit a673bb8e72fac6fe1cd02bc0edb1d092c5a3d3cb Merge: a441ed240c1 0df3700054b Author: JackieTien97 <[email protected]> AuthorDate: Sat May 11 17:50:15 2024 +0800 Merge remote-tracking branch 'origin/master' into tsbs/iot .../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 5 +- .../db/it/IoTDBSyntaxConventionIdentifierIT.java | 4 +- .../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 4 +- .../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 28 ++- .../cli/src/assembly/resources/tools/backup.sh | 2 +- .../org/apache/iotdb/tool/IoTDBDataBackTool.java | 112 +++++++----- .../org/apache/iotdb/session/pool/SessionPool.java | 10 ++ .../java/org/apache/iotdb/session/SessionTest.java | 6 + .../iotdb/confignode/manager/ConfigManager.java | 35 +++- .../iotdb/confignode/manager/load/LoadManager.java | 12 +- .../manager/load/service/HeartbeatService.java | 16 +- .../iotdb/confignode/manager/node/NodeManager.java | 6 +- .../pipe/execution/PipeConfigNodeSubtask.java | 64 ++++--- .../iotdb/confignode/persistence/AuthorInfo.java | 10 +- .../confignode/persistence/node/NodeInfo.java | 7 +- .../iotdb/confignode/service/ConfigNode.java | 28 ++- .../thrift/ConfigNodeRPCServiceProcessor.java | 4 +- .../org/apache/iotdb/db/auth/AuthorityChecker.java | 22 +-- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 24 ++- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 11 ++ .../client/IoTDBDataNodeAsyncClientManager.java | 4 + .../async/IoTDBDataRegionAsyncConnector.java | 116 +++++++----- .../PipeTransferTsFileInsertionEventHandler.java | 18 +- .../PipeRealtimeDataRegionHybridExtractor.java | 67 +++---- .../db/pipe/task/stage/PipeTaskExtractorStage.java | 13 ++ .../connector/PipeConnectorSubtaskManager.java | 13 ++ .../common/header/ColumnHeaderConstant.java | 12 ++ .../execution/load/AlignedChunkData.java | 3 + .../execution/load/LoadTsFileRateLimiter.java | 79 ++++++++ .../execution/load/NonAlignedChunkData.java | 3 + .../scheduler/load/LoadTsFileDispatcherImpl.java | 19 +- .../iotdb/db/storageengine/StorageEngine.java | 3 + .../db/storageengine/dataregion/DataRegion.java | 48 +++-- .../execute/task/AbstractCompactionTask.java | 8 +- .../execute/task/InnerSpaceCompactionTask.java | 3 + .../compaction/schedule/CompactionTaskManager.java | 6 +- .../dataregion/memtable/AbstractMemTable.java | 3 + .../dataregion/memtable/TsFileProcessor.java | 167 ++++++++++++++--- .../dataregion/memtable/WritableMemChunkGroup.java | 3 + .../db/storageengine/rescon/memory/SystemInfo.java | 2 +- .../SubscriptionConnectorSubtaskManager.java | 14 ++ .../dataregion/memtable/TsFileProcessorTest.java | 200 +++++++++++++++++++++ .../async/AsyncPipeDataTransferServiceClient.java | 13 +- .../apache/iotdb/commons/conf/CommonConfig.java | 11 ++ .../iotdb/commons/conf/CommonDescriptor.java | 5 + .../apache/iotdb/commons/conf/IoTDBConstant.java | 4 - .../commons/pipe/agent/plugin/PipePluginAgent.java | 10 +- .../iotdb/commons/pipe/config/PipeConfig.java | 7 + .../pipe/connector/client/IoTDBClientManager.java | 24 ++- .../connector/client/IoTDBSyncClientManager.java | 2 +- .../commons/pipe/progress/PipeEventCommitter.java | 17 ++ pom.xml | 2 +- 52 files changed, 1031 insertions(+), 278 deletions(-)
