This is an automated email from the ASF dual-hosted git repository. weihao pushed a commit to branch dev/1.3 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 71e4d64b18465d70fa4e2b4d311979a4129f28ec Merge: 64d21a70d89 5785485eb4f Author: Weihao Li <[email protected]> AuthorDate: Wed Mar 25 15:31:20 2026 +0800 Merge remote-tracking branch 'org/dev/1.3' into dev/1.3 example/pom.xml | 1 + {iotdb-client => example/subscription}/pom.xml | 30 +- .../apache/iotdb/SubscriptionSessionExample.java | 0 integration-test/pom.xml | 5 + .../iotdb/it/env/cluster/env/AbstractEnv.java | 25 + .../iotdb/it/env/remote/env/RemoteServerEnv.java | 5 + .../java/org/apache/iotdb/itbase/env/BaseEnv.java | 6 + .../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 109 +- .../db/it/orderBy/IoTDBOrderByForDebugIT.java | 1410 -------------------- .../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 67 +- iotdb-client/pom.xml | 1 + iotdb-client/service-rpc/pom.xml | 5 - iotdb-client/subscription/pom.xml | 81 ++ .../rpc/subscription/config/ConsumerConfig.java | 0 .../rpc/subscription/config/ConsumerConstant.java | 0 .../iotdb/rpc/subscription/config/TopicConfig.java | 0 .../rpc/subscription/config/TopicConstant.java | 0 .../exception/SubscriptionConnectionException.java | 0 .../exception/SubscriptionException.java | 0 .../SubscriptionIdentifierSemanticException.java | 0 .../SubscriptionIncompatibleHandlerException.java | 0 .../SubscriptionParameterNotValidException.java | 0 .../SubscriptionPayloadExceedException.java | 0 .../SubscriptionPipeTimeoutException.java | 0 .../SubscriptionPollTimeoutException.java | 0 .../SubscriptionRuntimeCriticalException.java | 0 .../exception/SubscriptionRuntimeException.java | 0 .../SubscriptionRuntimeNonCriticalException.java | 0 .../exception/SubscriptionTimeoutException.java | 0 .../subscription/payload/poll/ErrorPayload.java | 0 .../subscription/payload/poll/FileInitPayload.java | 0 .../payload/poll/FilePiecePayload.java | 0 .../subscription/payload/poll/FileSealPayload.java | 0 .../subscription/payload/poll/PollFilePayload.java | 0 .../rpc/subscription/payload/poll/PollPayload.java | 0 .../payload/poll/PollTabletsPayload.java | 0 .../payload/poll/SubscriptionCommitContext.java | 0 .../payload/poll/SubscriptionPollPayload.java | 0 .../payload/poll/SubscriptionPollRequest.java | 0 .../payload/poll/SubscriptionPollRequestType.java | 0 .../payload/poll/SubscriptionPollResponse.java | 0 .../payload/poll/SubscriptionPollResponseType.java | 0 .../subscription/payload/poll/TabletsPayload.java | 0 .../payload/poll/TerminationPayload.java | 0 .../payload/request/PipeSubscribeCloseReq.java | 0 .../payload/request/PipeSubscribeCommitReq.java | 0 .../payload/request/PipeSubscribeHandshakeReq.java | 0 .../payload/request/PipeSubscribeHeartbeatReq.java | 0 .../payload/request/PipeSubscribePollReq.java | 0 .../payload/request/PipeSubscribeRequestType.java | 0 .../request/PipeSubscribeRequestVersion.java | 0 .../payload/request/PipeSubscribeSubscribeReq.java | 0 .../request/PipeSubscribeUnsubscribeReq.java | 0 .../payload/response/PipeSubscribeCloseResp.java | 0 .../payload/response/PipeSubscribeCommitResp.java | 0 .../response/PipeSubscribeHandshakeResp.java | 0 .../response/PipeSubscribeHeartbeatResp.java | 0 .../payload/response/PipeSubscribePollResp.java | 0 .../response/PipeSubscribeResponseType.java | 0 .../response/PipeSubscribeResponseVersion.java | 0 .../response/PipeSubscribeSubscribeResp.java | 0 .../response/PipeSubscribeUnsubscribeResp.java | 0 .../session/subscription/SubscriptionSession.java | 0 .../SubscriptionSessionConnection.java | 0 .../session/subscription/consumer/AckStrategy.java | 0 .../subscription/consumer/AsyncCommitCallback.java | 0 .../subscription/consumer/ConsumeListener.java | 0 .../subscription/consumer/ConsumeResult.java | 0 .../consumer/SubscriptionConsumer.java | 0 .../SubscriptionExecutorServiceManager.java | 0 .../consumer/SubscriptionProvider.java | 0 .../consumer/SubscriptionProviders.java | 0 .../consumer/SubscriptionPullConsumer.java | 0 .../consumer/SubscriptionPushConsumer.java | 0 .../session/subscription/model/Subscription.java | 0 .../iotdb/session/subscription/model/Topic.java | 0 .../payload/SubscriptionFileHandler.java | 0 .../subscription/payload/SubscriptionMessage.java | 0 .../payload/SubscriptionMessageHandler.java | 0 .../payload/SubscriptionMessageType.java | 0 .../payload/SubscriptionRecordHandler.java | 0 .../payload/SubscriptionTsFileHandler.java | 0 .../session/subscription/util/CollectionUtils.java | 0 .../session/subscription/util/IdentifierUtils.java | 0 .../iotdb/session/subscription/util/PollTimer.java | 0 .../subscription/util/RandomStringGenerator.java | 0 .../session/subscription/util/SetPartitioner.java | 0 iotdb-core/confignode/pom.xml | 5 + iotdb-core/datanode/pom.xml | 5 + .../plan/planner/LogicalPlanVisitor.java | 5 + iotdb-core/node-commons/pom.xml | 5 + 91 files changed, 326 insertions(+), 1439 deletions(-)
