fix duplicated counting

Signed-off-by: Yi Jin <[email protected]>
databricks · Jun 4, 2024 · 49b78fc · 49b78fc
1 parent aad22e0
commit 49b78fc
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/receive/handler.go b/pkg/receive/handler.go
@@ -690,6 +690,10 @@ func (h *Handler) gatherWriteStats(writes ...map[endpointReplica]map[string]trac
 
 	for _, write := range writes {
 		for er := range write {
+			if er.replica != 0 {
+				// TODO: this is a temporary solution to avoid duplicated counting
+				continue
+			}
 			for tenant, series := range write[er] {
 				samples := 0