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 82049d7b46a Subscription: address topic owner review comments
add ed418844851 Implement subscription topic owner lease renewal
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/config/MppCommonConfig.java | 6 ++
.../env/cluster/config/MppSharedCommonConfig.java | 7 ++
.../it/env/remote/config/RemoteCommonConfig.java | 5 ++
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
.../it/local/AbstractSubscriptionLocalIT.java | 1 +
.../it/local/IoTDBSubscriptionTopicOwnerIT.java | 88 +++++++++++++++++++++
.../iotdb/confignode/manager/ConfigManager.java | 9 +++
.../apache/iotdb/confignode/manager/IManager.java | 4 +
.../iotdb/confignode/manager/ProcedureManager.java | 58 +++++++++++++-
.../subscription/SubscriptionCoordinator.java | 76 ++++++++++++++++++
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 ++
.../subscription/SubscriptionInfoTest.java | 26 +++++++
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 ++
.../subscription/agent/SubscriptionTopicAgent.java | 62 +++++++++++++++
.../receiver/SubscriptionReceiverV1.java | 83 +++++++++++++++++---
.../apache/iotdb/commons/conf/CommonConfig.java | 8 ++
.../iotdb/commons/conf/CommonDescriptor.java | 4 +
.../subscription/config/SubscriptionConfig.java | 2 +-
.../commons/subscription/meta/topic/TopicMeta.java | 59 ++++++++++++++
.../commons/subscription/topic/TopicDeSerTest.java | 90 ++++++++++++++++++++++
.../src/main/thrift/confignode.thrift | 10 +++
21 files changed, 598 insertions(+), 15 deletions(-)
