Add IPv4/v6 dual stack support in Flow aggregator

Fix the e2e test failure in dual stack cluster of flow aggregator.

test/e2e/fixtures.go

@@ -68,12 +68,6 @@ func skipIfNotIPv6Cluster(tb testing.TB) {
 	}
 }
 
-func skipIfDualStackCluster(tb testing.TB) {
-	if clusterInfo.podV6NetworkCIDR != "" && clusterInfo.podV4NetworkCIDR != "" {
-		tb.Skipf("Skipping test as it is not supported in dual stack cluster")
-	}
-}
-
 func skipIfMissingKernelModule(tb testing.TB, nodeName string, requiredModules []string) {
 	for _, module := range requiredModules {
 		// modprobe with "--dry-run" does not require root privileges
@@ -149,7 +143,7 @@ func setupTest(tb testing.TB) (*TestData, error) {
 
 func setupTestWithIPFIXCollector(tb testing.TB) (*TestData, bool, error) {
 	isIPv6 := false
-	if clusterInfo.podV6NetworkCIDR != "" {
+	if clusterInfo.podV6NetworkCIDR != "" && clusterInfo.podV4NetworkCIDR == "" {
 		isIPv6 = true
 	}
 	testData, err := setupTest(tb)

test/e2e/flowaggregator_test.go

@@ -102,7 +102,6 @@ const (
 )
 
 func TestFlowAggregator(t *testing.T) {
-	skipIfDualStackCluster(t)
 	data, isIPv6, err := setupTestWithIPFIXCollector(t)
 	if err != nil {
 		t.Fatalf("Error when setting up test: %v", err)
@@ -198,6 +197,7 @@ func checkRecordsForFlows(t *testing.T, data *TestData, srcIP string, dstIP stri
 		t.Errorf("Error when running iperf3 client: %v", err)
 	}
 	bandwidth := strings.TrimSpace(stdout)
+	t.Logf("cmd:%s, srcIP:%s, dstIP:%s, isIPv6:%v, bandwidth:%s", cmdStr, srcIP, dstIP, isIPv6, bandwidth)
 
 	// Polling to make sure all the data records corresponding to the iperf flow
 	// are received.