This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch fixIT0408-1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 83ac944046b fix
add 230cd633172 [to dev/1.3] fix: prevent NPE when isFinished() is called
before DataDriver init (#17441)
add 1f1d2c182c2 [To dev/1.3] Pipe: Fixed the OOM bug of tablet memory
calculation & Optimized the tablet size by memory estimation (#17451)
add 8ccd7c67600 [To dev/1.3] Subscription: Fixed the retry bug of
procedures & Pipe: Deleted some useless codes (#17455) (#17484)
add d34bd8d5aec [To dev/1.3] Pipe: Optimized the memory occupation of pipe
realtime source (#17450)(#17474) (#17486)
add c72b9675443 [To dev/1.3] Subscription: add removeUserData for messages
(#17479)
add 751c5c5829b Pipe: Refactor AirGap receiver with configurable payload
size control (#17443) (#17503)
add 8bf164037e7 [To dev/1.3] Improve state type validation in
CombineRequest deserialization. (#17449) (#17502)
add b8f33a6735c [To dev/1.3] Pipe: check file receiver write path (#17442)
(#17501)
add d6b0680dfd2 [To dev/1.3] Enhance the last query permission && Fixed
the rollback version of alter view / table plans && Deleted the unnecessary
mods in Tree view deletion (#17465) (#17494)
add 413b074e78c Pipe: Downgraded and reduced the log of
PipePushMetaRPCHandler (#17492) (#17519)
add c1556669dc3 Pipe: Fixed the OPC UA bug that drop pipe may not erase
the client (#17510) (#17522)
add 8d1ad63e955 [To dev/1.3] enhance cppclient tsblock deserialize
validation (#17464) (#17518)
add 9cadc71a819 [To dev/1.3] Load balance patch (#17463) (#17493) (#17527)
add ecef8f7cf83 [To dev/1.3] Pipe: Rewrote the OPC UA subscription logic
to avoid the bug of third-party subscription model (#17524)
add 4588b8d27a4 [To dev/1.3] Pipe: Upgraded bouncy castle && Added logs
for pipe tsFile parser (#17504) (#17523)
add 63ea91a83f8 [To dev/1.3] Enable show queries to be executed
immediately when the available memory in the memoryPool is insufficient (#17529)
add c74c9d946a9 Merge branch 'iotdb-dev1.3' into fixIT0408-1.3
add 72d1b3a28a4 Fix: send set configuration only to target nodes and
harden compaction schedule interruption handling (#17469)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 160 ++++++++++++++++++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 26 +++
.../iotdb/session/it/IoTDBSessionQueryIT.java | 79 +++++++++
.../it/local/IoTDBSubscriptionMessageIT.java | 184 +++++++++++++++++++++
iotdb-client/client-cpp/src/main/ColumnDecoder.cpp | 3 +
iotdb-client/client-cpp/src/main/Common.cpp | 46 +++++-
iotdb-client/client-cpp/src/main/Common.h | 8 +
iotdb-client/client-cpp/src/main/TsBlock.cpp | 12 ++
iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 67 ++++++++
.../consumer/SubscriptionConsumer.java | 51 +++---
.../consumer/SubscriptionPullConsumer.java | 29 ++--
.../subscription/payload/SubscriptionMessage.java | 23 +++
.../payload/SubscriptionMessageHandler.java | 5 +-
.../payload/SubscriptionRecordHandler.java | 30 ++++
.../async/handlers/rpc/PipePushMetaRPCHandler.java | 6 +-
.../manager/load/service/EventService.java | 5 +
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../AbstractOperateSubscriptionProcedure.java | 1 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 ++
.../container/TsFileInsertionDataContainer.java | 20 ++-
.../query/TsFileInsertionQueryDataContainer.java | 11 +-
.../scan/TsFileInsertionScanDataContainer.java | 14 +-
.../twostage/exchange/payload/CombineRequest.java | 10 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 25 ++-
.../visitor/PipeStatementTSStatusVisitor.java | 30 +---
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 92 +++--------
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 69 ++++----
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 158 ++++++++++++++++--
.../protocol/opcua/server/OpcUaServerBuilder.java | 14 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 1 -
.../async/handler/PipeTransferTsFileHandler.java | 5 +-
.../realtime/PipeRealtimeDataRegionSource.java | 11 ++
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 24 +--
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 72 +++++---
.../db/queryengine/common/MPPQueryContext.java | 14 ++
.../queryengine/execution/driver/DataDriver.java | 5 +
.../db/queryengine/execution/driver/Driver.java | 4 +-
.../queryengine/execution/driver/SchemaDriver.java | 5 +
.../execution/exchange/MPPDataExchangeManager.java | 56 ++++++-
.../execution/exchange/SharedTsBlockQueue.java | 57 ++++---
.../execution/exchange/sink/SinkChannel.java | 62 +++++--
.../execution/exchange/source/SourceHandle.java | 90 +++++++---
.../fragment/FragmentInstanceContext.java | 13 ++
.../fragment/FragmentInstanceManager.java | 2 +
.../queryengine/execution/memory/MemoryPool.java | 56 +++++--
.../db/queryengine/plan/analyze/Analysis.java | 2 +-
.../plan/analyze/ClusterPartitionFetcher.java | 30 +++-
.../queryengine/plan/execution/QueryExecution.java | 7 +-
.../plan/parser/StatementGenerator.java | 2 +-
.../plan/planner/OperatorTreeGenerator.java | 6 +-
.../plan/planner/plan/FragmentInstance.java | 2 +
.../schemaengine/schemaregion/ISchemaRegion.java | 4 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 6 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 4 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 7 +-
.../schedule/CompactionScheduleTaskManager.java | 9 +
.../schedule/CompactionScheduleTaskWorker.java | 21 ++-
.../compaction/schedule/TTLScheduleTask.java | 17 +-
.../event/TsFileInsertionDataContainerTest.java | 13 ++
.../protocol/airgap/IoTDBAirGapReceiverTest.java | 72 ++++++++
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 58 +++++++
.../db/queryengine/execution/DataDriverTest.java | 127 +++++++++++++-
.../execution/exchange/LocalSinkChannelTest.java | 10 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 11 +-
.../execution/exchange/ShuffleSinkHandleTest.java | 5 +-
.../execution/exchange/SourceHandleTest.java | 5 +-
.../db/queryengine/execution/exchange/Utils.java | 26 ++-
.../execution/memory/MemoryPoolTest.java | 116 +++++++++++--
.../apache/iotdb/commons/conf/CommonConfig.java | 30 +++-
.../apache/iotdb/commons/path/PathPatternTree.java | 49 +++---
.../connection/UnboundedBlockingPendingQueue.java | 4 +
.../iotdb/commons/pipe/config/PipeConfig.java | 7 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 5 +
.../pipe/config/constant/PipeSinkConstant.java | 5 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 37 +++--
.../pipe/receiver/IoTDBFileReceiverTest.java | 128 ++++++++++++++
pom.xml | 2 +-
77 files changed, 2090 insertions(+), 404 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionMessageIT.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiverTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiverTest.java
