This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch fix/subscription-broker-self-healing
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0d2ef238dd6 Fix subscription broker recovery rollback
add 50008fb3179 Serialize subscription broker repair with region creation
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/consensus/iot/IoTConsensus.java | 36 ++-
.../consensus/iot/IoTConsensusRecoveryTest.java | 22 ++
.../agent/SubscriptionBrokerAgent.java | 6 +
.../agent/SubscriptionConsumerAgent.java | 16 +-
.../broker/ConsensusSubscriptionBroker.java | 11 +
.../ConsensusSubscriptionSetupHandler.java | 247 ++++++++++++---------
.../ConsensusSubscriptionSetupHandlerTest.java | 172 +++++++++++++-
7 files changed, 386 insertions(+), 124 deletions(-)
