This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/benchant in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 91330db04b3992db860ae0fc759f921a2bb253b3 Merge: 659b08be5ac 387c2102600 Author: JackieTien97 <[email protected]> AuthorDate: Mon Jun 5 14:02:50 2023 +0800 Merge remote-tracking branch 'origin/master' into ty/benchant .../iotdb/confignode/manager/node/NodeManager.java | 9 +- .../confignode/persistence/pipe/PipeTaskInfo.java | 9 +- .../runtime/PipeHandleLeaderChangeProcedure.java | 8 +- .../runtime/PipeHandleMetaChangeProcedure.java | 24 +- .../impl/pipe/runtime/PipeMetaSyncProcedure.java | 8 +- .../pipe/task/AbstractOperatePipeProcedureV2.java | 8 + docs/UserGuide/Reference/Common-Config-Manual.md | 9 + .../zh/UserGuide/Reference/Common-Config-Manual.md | 9 + .../iotdb/db/it/view/IoTDBCreateAndShowViewIT.java | 294 ++++++++++++++ .../iotdb/pipe/api/collector/RowCollector.java | 5 +- .../resources/conf/iotdb-common.properties | 5 + .../commons/concurrent/ThreadPoolMetrics.java | 16 - .../apache/iotdb/commons/conf/CommonConfig.java | 31 +- .../consensus/index/impl/SimpleProgressIndex.java | 2 +- .../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 5 +- .../org/apache/iotdb/commons/utils/FileUtils.java | 12 + .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 21 +- .../mpp/common/schematree/ClusterSchemaTree.java | 4 +- .../db/pipe/agent/runtime/PipeAgentLauncher.java | 12 +- .../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 51 ++- .../impl/iotdb/v1/IoTDBThriftConnectorV1.java | 38 +- .../v1/request/PipeTransferInsertNodeReq.java | 4 +- .../event/impl/PipeEmptyTabletInsertionEvent.java} | 22 +- ...ava => PipeInsertNodeTabletInsertionEvent.java} | 31 +- ...nt.java => PipeTabletTabletInsertionEvent.java} | 6 +- .../realtime/PipeRealtimeCollectEventFactory.java | 6 +- .../core/event/realtime/TsFileEpochManager.java | 12 +- .../db/pipe/core/event/view/access/PipeRow.java | 22 +- .../event/view/collector/PipeRowCollector.java | 10 +- .../TabletInsertionDataContainer.java | 106 ++---- .../TsFileInsertionDataContainer.java | 4 +- .../db/sync/common/ClusterSyncInfoFetcher.java | 13 +- .../common/schematree/ClusterSchemaTreeTest.java | 21 + .../PipeInsertNodeTabletInsertionEventTest.java | 178 +++++++++ .../apache/iotdb/tsfile/write/record/Tablet.java | 422 +++++++++++++-------- .../iotdb/tsfile/write/record/TabletTest.java | 38 ++ 36 files changed, 1091 insertions(+), 384 deletions(-)
