Cleanup

rpcpool · May 9, 2024 · e2a146c · e2a146c
1 parent bd6ab88
commit e2a146c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/bucketteer/write.go b/bucketteer/write.go
@@ -11,6 +11,7 @@ import (
 
 	bin "github.com/gagliardetto/binary"
 	"github.com/rpcpool/yellowstone-faithful/indexmeta"
+	"k8s.io/klog/v2"
 )
 
 type Writer struct {
@@ -226,7 +227,7 @@ func seal(
 	for prefix := range prefixToHashes {
 		entries := getCleanSet(prefixToHashes[prefix])
 		if len(entries) != len(prefixToHashes[prefix]) {
-			panic(fmt.Sprintf("duplicate hashes for prefix %v", prefix))
+			klog.Errorf("duplicate hashes for prefix %v", prefix)
 		}
 		sortWithCompare(entries, func(i, j int) int {
 			if entries[i] < entries[j] {

diff --git a/deprecated/bucketteer/write.go b/deprecated/bucketteer/write.go
@@ -9,6 +9,7 @@ import (
 	"sort"
 
 	bin "github.com/gagliardetto/binary"
+	"k8s.io/klog/v2"
 )
 
 type Writer struct {
@@ -206,7 +207,7 @@ func seal(
 	for _, prefix := range prefixes {
 		entries := getCleanSet(prefixToHashes[prefix])
 		if len(entries) != len(prefixToHashes[prefix]) {
-			panic(fmt.Sprintf("duplicate hashes for prefix %v", prefix))
+			klog.Errorf("duplicate hashes for prefix %v", prefix)
 		}
 		sortWithCompare(entries, func(i, j int) int {
 			if entries[i] < entries[j] {