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)