This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
The following commit(s) were added to refs/heads/main by this push:
new 4d7560df Fix server got panic when create/update property with high
dist usage. (#879)
4d7560df is described below
commit 4d7560df32d1bfc7dc1aa349b0b301c55cb595de
Author: mrproliu <[email protected]>
AuthorDate: Wed Dec 3 21:27:42 2025 +0800
Fix server got panic when create/update property with high dist usage.
(#879)
* Fix server crash when create/update property with high dist usage.
---
CHANGES.md | 1 +
banyand/property/service.go | 2 +-
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/CHANGES.md b/CHANGES.md
index 32eb43ac..c614eeaf 100644
--- a/CHANGES.md
+++ b/CHANGES.md
@@ -13,6 +13,7 @@ Release Notes.
### Bug Fixes
- Fix the wrong retention setting of each measure/stream/trace.
+- Fix server got panic when create/update property with high dist usage.
### Document
diff --git a/banyand/property/service.go b/banyand/property/service.go
index e902dc02..97de409d 100644
--- a/banyand/property/service.go
+++ b/banyand/property/service.go
@@ -168,7 +168,7 @@ func (s *service) PreRun(ctx context.Context) error {
s.db.repairScheduler.registerClientToGossip(s.gossipMessenger)
}
return multierr.Combine(
- s.pipeline.Subscribe(data.TopicPropertyUpdate,
&updateListener{s: s, path: path, maxDiskUsagePercent: s.maxDiskUsagePercent}),
+ s.pipeline.Subscribe(data.TopicPropertyUpdate,
&updateListener{s: s, l: s.l, path: path, maxDiskUsagePercent:
s.maxDiskUsagePercent}),
s.pipeline.Subscribe(data.TopicPropertyDelete,
&deleteListener{s: s}),
s.pipeline.Subscribe(data.TopicPropertyQuery, &queryListener{s:
s}),
s.pipeline.Subscribe(data.TopicSnapshot, snapshotLis),
