Bug fix for inter-node traffic

For flows that do not need correlation, ReadyToSend and areCorrelatedFieldsFilled should always be false.

Signed-off-by: Yun-Tang Hsu <[email protected]>

pkg/intermediate/aggregate.go

@@ -408,18 +408,6 @@ func (a *AggregationProcess) addOrUpdateRecordInMap(flowKey *FlowKey, record ent
 			waitForReadyToSendRetries: 0,
 			isIPv4:                    isIPv4,
 		}
-
-		if !correlationRequired {
-			aggregationRecord.ReadyToSend = true
-			// If no correlation is required for an Inter-Node record, K8s metadata is
-			// expected to be not completely filled. For Intra-Node flows and ToExternal
-			// flows, areCorrelatedFieldsFilled is set to true by default.
-			if flowType == registry.FlowTypeInterNode {
-				aggregationRecord.areCorrelatedFieldsFilled = false
-			} else {
-				aggregationRecord.areCorrelatedFieldsFilled = true
-			}
-		}
 		aggregationRecord.areExternalFieldsFilled = false
 		// Push the record to the priority queue.
 		pqItem := &ItemToExpire{
@@ -432,6 +420,11 @@ func (a *AggregationProcess) addOrUpdateRecordInMap(flowKey *FlowKey, record ent
 		pqItem.inactiveExpireTime = currTime.Add(a.inactiveExpiryTimeout)
 		heap.Push(&a.expirePriorityQueue, pqItem)
 	}
+	// For flows that do not need correlation, ReadyToSend and areCorrelatedFieldsFilled should always be false.
+	if !correlationRequired {
+		aggregationRecord.ReadyToSend = true
+		aggregationRecord.areCorrelatedFieldsFilled = true
+	}
 	a.flowKeyRecordMap[*flowKey] = aggregationRecord
 	return nil
 }