This is an automated email from the ASF dual-hosted git repository.
ColinLeeo pushed a change to branch fix/tablet-out-of-order-seq-overlap
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 084716337c5 Fix sequence space overlap caused by out-of-order tablets
add d452dddc932 Fix unexpected exception when kill query beacuse of
concurrent cleanup of resources (#19033)
add 8cdc9681d01 [C++] Fix macOS OpenSSL header isolation and upgrade
Thrift to 0.25.0 (#18968)
add de1214a73b5 Support progress retention for initial and snapshot
subscription topics (#19019)
add ca95a046c22 Add ready DataNodes to subscription details (#19030)
add b1ea6b52ebd Document IT cluster reuse and test isolation (#19046)
add e616dc50c1f Add credential strength baseline for test-created users in
IT guidance (#19045)
add 7de7c285eee Merge remote-tracking branch 'apache/master' into
fix/seq-overlap-read-side
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 16 +-
integration-test/AGENTS.md | 16 +
.../it/local/IoTDBSubscriptionBasicIT.java | 134 +++++
iotdb-client/client-cpp/CMakeLists.txt | 9 +-
iotdb-client/client-cpp/README.md | 18 +-
iotdb-client/client-cpp/README_zh.md | 3 +
iotdb-client/client-cpp/cmake/FetchBoost.cmake | 17 +-
.../client-cpp/cmake/FetchBuildTools.cmake | 2 +-
iotdb-client/client-cpp/cmake/FetchOpenSSL.cmake | 2 +-
iotdb-client/client-cpp/examples/README.md | 2 +-
iotdb-client/client-cpp/examples/README_zh.md | 2 +-
.../package-metadata/third_party/DEPENDENCIES.md | 2 +-
.../client-cpp/test/cmake/FetchBoostTest.cmake | 68 +++
.../test/cmake/cxx11-consumer}/CMakeLists.txt | 25 +-
.../test/cmake/cxx11-consumer/main.cpp} | 17 +-
iotdb-client/client-cpp/third-party/README.md | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 13 +
.../runtime/heartbeat/PipeHeartbeatParser.java | 47 +-
.../manager/subscription/SubscriptionManager.java | 6 +
.../SubscriptionReadyDataNodeTracker.java | 128 +++++
.../persistence/subscription/SubscriptionInfo.java | 112 +++-
.../procedure/env/ConfigNodeProcedureEnv.java | 7 +-
.../AbstractOperateSubscriptionProcedure.java | 24 +-
.../consumer/AlterConsumerGroupProcedure.java | 21 +-
.../subscription/CreateSubscriptionProcedure.java | 25 +-
.../subscription/DropSubscriptionProcedure.java | 4 +
.../subscription/topic/AlterTopicProcedure.java | 240 ++++++++-
.../subscription/topic/DropTopicProcedure.java | 267 ++++++++-
.../procedure/store/ProcedureFactory.java | 21 +-
.../confignode/procedure/store/ProcedureType.java | 3 +
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 149 +++++-
.../SubscriptionReadyDataNodeTrackerTest.java | 77 +++
.../subscription/SubscriptionInfoTest.java | 52 ++
.../SubscriptionInfoTopicValidationTest.java | 43 +-
.../consumer/DropConsumerProcedureTest.java | 62 +++
.../CreateSubscriptionProcedureTest.java | 114 ++++
.../DropSubscriptionProcedureTest.java | 37 ++
.../topic/AlterTopicProcedureTest.java | 7 +
.../subscription/topic/DropTopicProcedureTest.java | 282 ++++++++++
.../iotdb/db/i18n/DataNodeQueryMessages.java | 3 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 2 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 57 ++
.../queryengine/plan/execution/QueryExecution.java | 16 +-
.../sys/subscription/ShowSubscriptionsTask.java | 7 +
.../agent/SubscriptionBrokerAgent.java | 8 +
.../agent/SubscriptionConsumerAgent.java | 52 +-
.../db/subscription/broker/SubscriptionBroker.java | 66 ++-
.../broker/SubscriptionPrefetchingQueue.java | 33 ++
.../db/subscription/event/SubscriptionEvent.java | 6 +
.../pipe/SubscriptionPipeTabletBatchEvents.java | 5 +
.../response/SubscriptionEventTabletResponse.java | 3 +
.../plan/execution/QueryExecutionRetryTest.java | 47 ++
.../subscription/ShowSubscriptionsTaskTest.java | 3 +
.../agent/SubscriptionConsumerAgentTest.java | 140 +++++
.../SubscriptionRetainedInitialReplayTest.java | 596 +++++++++++++++++++++
.../SubscriptionPipeTabletEventBatchTest.java | 36 ++
.../pipe/config/constant/SystemConstant.java | 3 +
.../schema/column/ColumnHeaderConstant.java | 4 +-
.../meta/consumer/CommitProgressKeeper.java | 14 +
.../meta/consumer/ConsumerGroupMeta.java | 53 +-
.../consumer/ConsumerGroupDeSerTest.java | 35 ++
.../src/main/thrift/confignode.thrift | 1 +
62 files changed, 3125 insertions(+), 145 deletions(-)
create mode 100644 iotdb-client/client-cpp/test/cmake/FetchBoostTest.cmake
copy {example/rest-client-c-example =>
iotdb-client/client-cpp/test/cmake/cxx11-consumer}/CMakeLists.txt (50%)
copy
iotdb-client/{service-rpc/src/main/java/org/apache/iotdb/rpc/ConfigNodeConnectionException.java
=> client-cpp/test/cmake/cxx11-consumer/main.cpp} (71%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionReadyDataNodeTracker.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionReadyDataNodeTrackerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/agent/SubscriptionRetainedInitialReplayTest.java
