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 8621c5d32b5 Use duration-based subscription owner lease renewal
add 19e285247ac Renew subscription owner leases in ConfigNode heartbeat
No new revisions were added by this update.
Summary of changes:
.../it/local/IoTDBSubscriptionTopicOwnerIT.java | 3 +-
.../iotdb/confignode/manager/ConfigManager.java | 9 -----
.../apache/iotdb/confignode/manager/IManager.java | 4 --
.../iotdb/confignode/manager/ProcedureManager.java | 31 --------------
.../manager/load/service/HeartbeatService.java | 10 +++++
.../subscription/SubscriptionCoordinator.java | 47 +++++++++-------------
.../persistence/subscription/SubscriptionInfo.java | 27 +++++++++++++
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 ---
.../subscription/SubscriptionInfoTest.java | 40 ++++++++++++++++++
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 ----
.../impl/DataNodeInternalRPCServiceImpl.java | 14 +++++++
.../subscription/agent/SubscriptionTopicAgent.java | 30 --------------
.../receiver/SubscriptionReceiverV1.java | 47 ----------------------
.../commons/subscription/meta/topic/TopicMeta.java | 10 +++++
.../src/main/thrift/confignode.thrift | 10 -----
.../src/main/thrift/datanode.thrift | 1 +
16 files changed, 123 insertions(+), 173 deletions(-)
