This is an automated email from the ASF dual-hosted git repository.
VGalaxies pushed a change to branch subscription-topic-owner-fencing
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 19e285247ac Renew subscription owner leases in ConfigNode heartbeat
add 1e80cc0afd5 Rework subscription topic owner epoch fencing and lease
No new revisions were added by this update.
Summary of changes:
.../IoTDBSubscriptionTopicOwnerPartitionIT.java | 263 +++++++++++++++++++++
.../it/local/IoTDBSubscriptionTopicOwnerIT.java | 65 +----
.../rpc/subscription/config/TopicConstant.java | 5 +-
.../subscription/AbstractSubscriptionSession.java | 4 +-
.../client/async/CnToDnAsyncRequestType.java | 1 +
.../CnToDnInternalServiceAsyncRequestManager.java | 6 +
.../iotdb/confignode/manager/ProcedureManager.java | 52 ++--
.../manager/load/service/HeartbeatService.java | 10 -
.../subscription/SubscriptionCoordinator.java | 107 ++++++---
.../subscription/SubscriptionOwnerLeaseSyncer.java | 96 ++++++++
.../persistence/subscription/SubscriptionInfo.java | 35 +--
.../subscription/SubscriptionInfoTest.java | 133 ++---------
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 2 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 2 +
.../impl/DataNodeInternalRPCServiceImpl.java | 29 +--
.../subscription/agent/SubscriptionTopicAgent.java | 26 ++
.../receiver/SubscriptionReceiverV1.java | 9 +
.../commons/subscription/meta/topic/TopicMeta.java | 242 +++++++------------
.../commons/subscription/topic/TopicDeSerTest.java | 172 ++++++--------
.../src/main/thrift/datanode.thrift | 22 +-
20 files changed, 740 insertions(+), 541 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/cluster/IoTDBSubscriptionTopicOwnerPartitionIT.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionOwnerLeaseSyncer.java
