This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/kill
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0a13d70c743 Fix kill query doesn't take effect bug
add 038e7d8746d [To dev/1.3] Subscription: split client and example
modules (#17326)
add 82ed55fc122 Remove IoTDBOrderByForDebugIT. #17351
add d243a109492 [To dev/1.3] Fixed the REST partial insert & Pipe: Added
partial insert IT (#17339)
add 0b67cb824eb [To dev/1.3] Add extra client_ip and timeout columns for
show queries
new 43f2e8d2cfa Merge remote-tracking branch 'origin/dev/1.3' into ty/kill
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:
example/pom.xml | 1 +
example/{mqtt-customize => subscription}/pom.xml | 7 +-
.../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/{isession => subscription}/pom.xml | 39 +-
.../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 +
.../org/apache/iotdb/db/audit/AuditLogger.java | 2 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 2 +-
.../protocol/legacy/loader/DeletionLoader.java | 2 +-
.../protocol/legacy/loader/TsFileLoader.java | 2 +-
.../sink/protocol/writeback/WriteBackSink.java | 2 +-
.../iotdb/db/protocol/session/SessionManager.java | 6 +-
.../db/queryengine/common/MPPQueryContext.java | 7 +
.../iotdb/db/queryengine/common/SessionInfo.java | 16 +-
.../common/header/ColumnHeaderConstant.java | 8 +-
.../fragment/FragmentInstanceContext.java | 4 +-
.../operator/source/ShowQueriesOperator.java | 3 +
.../plan/execution/IQueryExecution.java | 5 +
.../queryengine/plan/execution/QueryExecution.java | 10 +
.../plan/execution/config/ConfigExecution.java | 10 +
.../plan/planner/LogicalPlanVisitor.java | 5 +
.../planner/plan/node/source/ShowQueriesNode.java | 12 +-
.../metrics/IoTDBInternalLocalReporter.java | 2 +-
.../load/active/ActiveLoadTsFileLoader.java | 2 +-
.../execution/operator/MergeSortOperatorTest.java | 10 +
.../db/queryengine/plan/analyze/AnalyzeTest.java | 2 +-
.../plan/optimization/LimitOffsetPushDownTest.java | 2 +-
.../plan/planner/FragmentInstanceSerdeTest.java | 3 +-
.../planner/logical/LogicalPlannerTestUtil.java | 2 +-
iotdb-core/node-commons/pom.xml | 5 +
113 files changed, 357 insertions(+), 1457 deletions(-)
copy example/{mqtt-customize => subscription}/pom.xml (88%)
rename example/{session =>
subscription}/src/main/java/org/apache/iotdb/SubscriptionSessionExample.java
(100%)
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/orderBy/IoTDBOrderByForDebugIT.java
copy iotdb-client/{isession => subscription}/pom.xml (75%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/config/ConsumerConfig.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/config/ConsumerConstant.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/config/TopicConfig.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/config/TopicConstant.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionConnectionException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionIdentifierSemanticException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionIncompatibleHandlerException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionParameterNotValidException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionPayloadExceedException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionPipeTimeoutException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionPollTimeoutException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionRuntimeCriticalException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionRuntimeException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionRuntimeNonCriticalException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionTimeoutException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/ErrorPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/FileInitPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/FilePiecePayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/FileSealPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/PollFilePayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/PollPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/PollTabletsPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionCommitContext.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollRequest.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollRequestType.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollResponse.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollResponseType.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/TabletsPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/TerminationPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeCloseReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeCommitReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeHandshakeReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeHeartbeatReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribePollReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeRequestType.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeRequestVersion.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeSubscribeReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeUnsubscribeReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeCloseResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeCommitResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeHandshakeResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeHeartbeatResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribePollResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeResponseType.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeResponseVersion.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeSubscribeResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeUnsubscribeResp.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSession.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSessionConnection.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/AckStrategy.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/AsyncCommitCallback.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/ConsumeListener.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/ConsumeResult.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionConsumer.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionExecutorServiceManager.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionProvider.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionProviders.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionPullConsumer.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionPushConsumer.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/model/Subscription.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/model/Topic.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionFileHandler.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionMessage.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionMessageHandler.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionMessageType.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionRecordHandler.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionTsFileHandler.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/CollectionUtils.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/IdentifierUtils.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/PollTimer.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/RandomStringGenerator.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/SetPartitioner.java
(100%)
