This is an automated email from the ASF dual-hosted git repository.
spricoder pushed a change to branch feature/disk-metric
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 310e5165542 Merge branch 'master' into feature/disk-metric
add 3f8c344b3a8 Pipe: fix file handle leak when processing with
extractor.pattern (#11209)
add b4c2caeaf2f Manipulate series of Audit and IoTDB reporter as super user
add 5c7718ea8fa Pipe: Add IT for different cluster config and consensus
protocols (#11097)
add 8980844590a Add UT for session module (#11158)
add 53a2bee7b20 Fix the dead lock bug when the generated distributed query
plan contains cycle
add 0cb79e5f07e [IoTDB-6172] Finish canAddTsBlock of SharedTsBlockQueue to
ensure that blocked Driver could be correctly finished
add 9a7e114a5b6 Ensure concurrency safety when updating last cache
add 2fd218422b6 Optimize the python client performance for Python 3.10 or
later (#11198)
add 1c3a59e4b9b Pipe: Added tablet event count and tsfile event count to
PipeHeartbeatEvent reports (#11225)
add 6e7088ae6ae [IOTDB-6170] Pipe: Removed unnecessary parse when tsFile
resources' time ranges are covered by startTime-endTime (#11211)
new 9584c23b309 Merge branch 'master' into feature/disk-metric
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeProtocolIT.java
create mode 100644
iotdb-client/session/src/test/java/org/apache/iotdb/session/SessionConnectionTest.java
create mode 100644
iotdb-client/session/src/test/java/org/apache/iotdb/session/SessionTest.java
create mode 100644
iotdb-client/session/src/test/java/org/apache/iotdb/session/pool/SessionPoolExceptionTest.java
create mode 100644
iotdb-client/session/src/test/java/org/apache/iotdb/session/util/SessionUtilsTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/connection/EnrichedDeque.java
