[ingester] fix application log counter leak

deepflowio · May 24, 2024 · 9e76a00 · 9e76a00
1 parent 2b0a525
commit 9e76a00
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/server/ingester/app_log/decoder/decoder.go b/server/ingester/app_log/decoder/decoder.go
@@ -21,6 +21,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"net"
+	"strconv"
 	"strings"
 	"time"
 
@@ -152,6 +153,7 @@ func (d *Decoder) GetCounter() interface{} {
 func (d *Decoder) Run() {
 	log.Infof("application log (%s-%d) decoder run", d.msgType.String(), d.index)
 	ingestercommon.RegisterCountableForIngester("decoder", d, stats.OptionStatTags{
+		"thread":   strconv.Itoa(d.index),
 		"msg_type": d.msgType.String()})
 	buffer := make([]interface{}, BUFFER_SIZE)
 	decoder := &codec.SimpleDecoder{}