This is an automated email from the ASF dual-hosted git repository. spricoder pushed a commit to branch feature/disk-metric in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 9584c23b309c76b32c5c2d499bf8ffb0a87ea08f Merge: 310e5165542 6e7088ae6ae Author: spricoder <[email protected]> AuthorDate: Wed Sep 27 19:45:42 2023 +0800 Merge branch 'master' into feature/disk-metric .../iotdb/it/env/cluster/ClusterConstant.java | 2 + .../it/env/cluster/config/MppCommonConfig.java | 6 + .../env/cluster/config/MppSharedCommonConfig.java | 7 + .../iotdb/it/env/cluster/env/AbstractEnv.java | 10 +- .../iotdb/it/env/cluster/env/Cluster1Env.java | 6 + .../iotdb/it/env/cluster/env/MultiClusterEnv.java | 6 + .../apache/iotdb/it/env/cluster/env/SimpleEnv.java | 6 + .../iotdb/it/env/cluster/node/DataNodeWrapper.java | 9 + .../it/env/remote/config/RemoteCommonConfig.java | 5 + .../iotdb/it/env/remote/env/RemoteServerEnv.java | 6 + .../java/org/apache/iotdb/itbase/env/BaseEnv.java | 9 + .../org/apache/iotdb/itbase/env/CommonConfig.java | 2 + .../org/apache/iotdb/db/it/utils/TestUtils.java | 98 ++ .../apache/iotdb/pipe/it/IoTDBPipeClusterIT.java | 766 ++++++++++++ .../apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java | 469 +++++--- .../apache/iotdb/pipe/it/IoTDBPipeProtocolIT.java | 415 +++++++ .../iotdb/pipe/it/IoTDBPipeSwitchStatusIT.java | 23 +- .../pipe/it/extractor/IoTDBPipeExtractorIT.java | 151 +-- .../org/apache/iotdb/pipe/api/PipeConnector.java | 10 +- .../org/apache/iotdb/pipe/api/PipeProcessor.java | 10 +- .../event/dml/insertion/TsFileInsertionEvent.java | 2 +- .../main/java/org/apache/iotdb/tool/ImportCsv.java | 2 +- iotdb-client/client-py/iotdb/Session.py | 57 +- .../iotdb/tsfile/utils/ReadWriteIOUtils.py | 12 +- .../client-py/iotdb/utils/IoTDBConstants.py | 33 +- iotdb-client/client-py/iotdb/utils/NumpyTablet.py | 8 +- iotdb-client/client-py/iotdb/utils/Tablet.py | 14 +- .../iotdb/session/SessionConnectionTest.java | 388 ++++++ .../java/org/apache/iotdb/session/SessionTest.java | 1175 ++++++++++++++++++ .../session/pool/SessionPoolExceptionTest.java | 266 ++++ .../apache/iotdb/session/pool/SessionPoolTest.java | 1264 +++++++++++++++++++- .../iotdb/session/util/SessionUtilsTest.java | 176 +++ .../org/apache/iotdb/db/audit/AuditLogger.java | 7 +- .../protocol/airgap/IoTDBAirGapConnector.java | 8 +- .../thrift/async/IoTDBThriftAsyncConnector.java | 8 +- .../protocol/websocket/WebSocketConnector.java | 12 +- .../event/common/heartbeat/PipeHeartbeatEvent.java | 49 +- .../common/tsfile/PipeTsFileInsertionEvent.java | 31 +- .../tsfile/TsFileInsertionDataContainer.java | 1 + .../PipeHistoricalDataRegionTsFileExtractor.java | 8 +- .../PipeRealtimeDataRegionHybridExtractor.java | 2 +- .../pipe/task/connection/BlockingPendingQueue.java | 57 +- .../db/pipe/task/connection/EnrichedDeque.java | 98 ++ .../pipe/task/connection/PipeEventCollector.java | 5 +- .../connection/UnboundedBlockingPendingQueue.java | 60 - .../execution/exchange/SharedTsBlockQueue.java | 9 + .../analyze/cache/schema/DataNodeSchemaCache.java | 43 +- .../analyze/cache/schema/SchemaCacheEntry.java | 16 +- .../cache/schema/TimeSeriesSchemaCache.java | 62 +- .../schema/dualkeycache/impl/DualKeyCacheImpl.java | 65 +- .../dualkeycache/impl/FIFOCacheEntryManager.java | 7 +- .../schema/dualkeycache/impl/ICacheEntry.java | 2 + .../dualkeycache/impl/LRUCacheEntryManager.java | 7 +- .../schema/lastcache/DataNodeLastCacheManager.java | 6 +- .../distribution/DistributionPlanContext.java | 5 +- .../planner/distribution/DistributionPlanner.java | 6 +- .../planner/distribution/ExchangeNodeAdder.java | 72 +- .../planner/distribution/NodeGroupContext.java | 18 +- .../plan/planner/distribution/SourceRewriter.java | 76 +- .../node/process/last/LastQueryTransformNode.java | 7 + .../planner/plan/node/sink/IdentitySinkNode.java | 5 + .../plan/node/source/AlignedSeriesScanNode.java | 4 +- .../metrics/IoTDBInternalLocalReporter.java | 3 +- .../cache/dualkeycache/DualKeyCacheTest.java | 4 +- 64 files changed, 5538 insertions(+), 638 deletions(-)
