diff --git a/src/replica/replica_context.cpp b/src/replica/replica_context.cpp index 6061b01da0..7b4fa40b97 100644 --- a/src/replica/replica_context.cpp +++ b/src/replica/replica_context.cpp @@ -252,6 +252,10 @@ bool partition_split_context::cleanup(bool force) CLEANUP_TASK(check_state_task, force) } + splitting_start_ts_ns = 0; + splitting_start_async_learn_ts_ns = 0; + splitting_copy_file_count = 0; + splitting_copy_file_size = 0; parent_gpid.set_app_id(0); is_prepare_list_copied = false; is_caught_up = false; diff --git a/src/replica/replica_stub.cpp b/src/replica/replica_stub.cpp index 77c3e80c62..be3017ab08 100644 --- a/src/replica/replica_stub.cpp +++ b/src/replica/replica_stub.cpp @@ -1846,6 +1846,10 @@ void replica_stub::on_gc() _counter_bulk_load_running_count->set(bulk_load_running_count); _counter_bulk_load_max_ingestion_time_ms->set(bulk_load_max_ingestion_time_ms); _counter_bulk_load_max_duration_time_ms->set(bulk_load_max_duration_time_ms); + _counter_replicas_splitting_count->set(splitting_count); + _counter_replicas_splitting_max_duration_time_ms->set(splitting_max_duration_time_ms); + _counter_replicas_splitting_max_async_learn_time_ms->set(splitting_max_async_learn_time_ms); + _counter_replicas_splitting_max_copy_file_size->set(splitting_max_copy_file_size); ddebug("finish to garbage collection, time_used_ns = %" PRIu64, dsn_now_ns() - start); } diff --git a/src/replica/split/replica_split_manager.cpp b/src/replica/split/replica_split_manager.cpp index 0f7652a81e..554ddda27f 100644 --- a/src/replica/split/replica_split_manager.cpp +++ b/src/replica/split/replica_split_manager.cpp @@ -1068,6 +1068,7 @@ void replica_split_manager::child_partition_active( return; } + _stub->_counter_replicas_splitting_recent_split_succ_count->increment(); _replica->_primary_states.last_prepare_decree_on_new_primary = _replica->_prepare_list->max_decree(); _replica->update_configuration(config);