diff --git a/test/e2e/fixtures.go b/test/e2e/fixtures.go index 9f15fed5992..0e4659b2e52 100644 --- a/test/e2e/fixtures.go +++ b/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) diff --git a/test/e2e/flowaggregator_test.go b/test/e2e/flowaggregator_test.go index 1ea578c1212..84d22cc41da 100644 --- a/test/e2e/flowaggregator_test.go +++ b/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.