This is an automated email from the ASF dual-hosted git repository. Wei-hao-Li pushed a commit to branch fixDeviceEntryConf in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 639d3b9ee28d2a35a962cf499cf005cbe38bc9a3 Merge: 547fda5f155 c611a389e7d Author: Weihao Li <[email protected]> AuthorDate: Thu Sep 17 17:42:14 2026 +0800 Merge branch 'master' of github.com:apache/iotdb into mast .../org/apache/iotdb/TableModelJDBCExample.java | 8 +- .../apache/iotdb/session/SessionConnection.java | 26 ++ .../iotdb/session/SessionConnectionTest.java | 19 ++ .../subscription/i18n/SubscriptionMessages.java | 2 + .../subscription/i18n/SubscriptionMessages.java | 2 + .../SubscriptionSessionConnection.java | 8 + .../base/AbstractSubscriptionConsumer.java | 37 ++- .../base/AbstractSubscriptionProvider.java | 96 +++++-- .../base/AbstractSubscriptionProviders.java | 62 ++++- .../base/AbstractSubscriptionPullConsumer.java | 86 +++--- .../base/AbstractSubscriptionPushConsumer.java | 20 +- .../SubscriptionSessionConnectionTimeoutTest.java | 148 ++++++++++ .../SubscriptionConsumerConnectionFailureTest.java | 167 ++++++++++++ .../base/SubscriptionConsumerLifecycleTest.java | 96 ++++++- .../iotdb/confignode/i18n/ManagerMessages.java | 8 + .../iotdb/confignode/i18n/ManagerMessages.java | 8 + .../iotdb/confignode/manager/ProcedureManager.java | 31 ++- .../manager/partition/PartitionManager.java | 21 +- .../persistence/subscription/SubscriptionInfo.java | 8 +- .../ProcedureManagerReconstructRegionTest.java | 169 ++++++++++++ .../iotdb/db/i18n/DataNodeQueryMessages.java | 3 + .../iotdb/db/i18n/DataNodeQueryMessages.java | 2 + .../agent/task/subtask/sink/PipeSinkSubtask.java | 59 +++- .../task/subtask/sink/PipeSinkSubtaskManager.java | 4 +- .../deletion/persist/PageCacheDeletionBuffer.java | 67 +++-- .../db/queryengine/common/MPPQueryContext.java | 47 +++- .../plan/planner/LocalExecutionPlanner.java | 10 +- .../memory/OperatorMemoryNotEnoughException.java | 43 +++ .../dataregion/wal/buffer/AbstractWALBuffer.java | 39 ++- .../dataregion/wal/buffer/WALBuffer.java | 81 +++++- .../storageengine/dataregion/wal/io/LogWriter.java | 39 +-- .../storageengine/dataregion/wal/io/WALWriter.java | 5 +- .../broker/ConsensusSubscriptionBroker.java | 171 ++++++++---- .../consensus/ConsensusPrefetchingQueue.java | 18 +- .../task/subtask/SubscriptionSinkSubtask.java | 5 +- .../task/subtask/sink/PipeSinkSubtaskTest.java | 123 ++++++++- .../persist/PageCacheDeletionBufferTest.java | 88 ++++++ .../db/queryengine/common/MPPQueryContextTest.java | 58 ++++ .../wal/buffer/WALBufferRollRecoveryTest.java | 300 +++++++++++++++++++++ .../dataregion/wal/io/WALFileTest.java | 15 ++ .../ConsensusSubscriptionBrokerOwnershipTest.java | 192 +++++++++++++ .../consensus/ConsensusPrefetchingQueueTest.java | 54 ++++ .../agent/plugin/builtin/BuiltinPipePlugin.java | 33 +++ .../meta/consumer/ConsumerGroupMeta.java | 31 +-- .../consumer/ConsumerGroupDeSerTest.java | 26 ++ 45 files changed, 2276 insertions(+), 259 deletions(-)
