You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by li...@apache.org on 2025/08/06 12:10:37 UTC

(skywalking-banyandb) 01/01: Add debug log of property repair

This is an automated email from the ASF dual-hosted git repository.

liuhan pushed a commit to branch property-log
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git

commit 102df30dba8525ebed6f522d3a048926d7d6ac84
Author: mrproliu <74...@qq.com>
AuthorDate: Wed Aug 6 20:10:25 2025 +0800

    Add debug log of property repair
---
 banyand/property/db.go     | 1 +
 banyand/property/repair.go | 1 +
 2 files changed, 2 insertions(+)

diff --git a/banyand/property/db.go b/banyand/property/db.go
index ea5475ab..ec4a87a4 100644
--- a/banyand/property/db.go
+++ b/banyand/property/db.go
@@ -100,6 +100,7 @@ func openDB(
 	}
 	var err error
 	// init repair scheduler
+	l.Debug().Bool("enabled", repairEnabled).Str("repair_trigger", repairTriggerCron).Msg("repair scheduler enabled")
 	if repairEnabled {
 		scheduler, schedulerErr := newRepairScheduler(l, omr, repairBuildTreeCron, repairQuickBuildTreeTime, repairTriggerCron,
 			gossipMessenger, repairSlotCount, db, buildSnapshotFunc)
diff --git a/banyand/property/repair.go b/banyand/property/repair.go
index d06cb0cd..d2fdf695 100644
--- a/banyand/property/repair.go
+++ b/banyand/property/repair.go
@@ -1141,6 +1141,7 @@ func (r *repairScheduler) close() {
 }
 
 func (r *repairScheduler) doRepairGossip(ctx context.Context) error {
+	r.l.Debug().Msg("starting repair gossip scheduler")
 	group, shardNum, err := r.randomSelectGroup(ctx)
 	if err != nil {
 		return fmt.Errorf("selecting random group failure: %w", err)