diff --git a/pkg/pipeline/extract/conntrack/store.go b/pkg/pipeline/extract/conntrack/store.go index 8377c95c9..9e0b1505e 100644 --- a/pkg/pipeline/extract/conntrack/store.go +++ b/pkg/pipeline/extract/conntrack/store.go @@ -78,7 +78,10 @@ func (cs *connectionStore) addConnection(hashId uint64, conn connection) { } func (cs *connectionStore) getConnection(hashId uint64) (connection, bool) { - groupIdx := cs.hashId2groupIdx[hashId] + groupIdx, found := cs.hashId2groupIdx[hashId] + if !found { + return nil, false + } mom := cs.groups[groupIdx].mom record, ok := mom.GetRecord(utils.Key(hashId))