diff --git a/test/e2e/e2e_test.go b/test/e2e/e2e_test.go
index 6b25ba285..42d361480 100644
--- a/test/e2e/e2e_test.go
+++ b/test/e2e/e2e_test.go
@@ -18,6 +18,7 @@ package e2e
 
 import (
 	"flag"
+	"fmt"
 	"math/rand"
 	"os"
 	"testing"
@@ -29,6 +30,11 @@ import (
 	"k8s.io/kubernetes/test/e2e/framework/testfiles"
 )
 
+var (
+	dockerRepo = flag.String("nfd.repo", "registry.k8s.io/nfd/node-feature-discovery", "Docker repository to fetch image from")
+	dockerTag  = flag.String("nfd.tag", "v0.12.0", "Docker tag to use")
+)
+
 // handleFlags sets up all flags and parses the command line.
 func handleFlags() {
 	config.CopyFlags(config.Flags, flag.CommandLine)
@@ -37,6 +43,11 @@ func handleFlags() {
 	flag.Parse()
 }
 
+// must be called after flags are parsed
+func dockerImage() string {
+	return fmt.Sprintf("%s:%s", *dockerRepo, *dockerTag)
+}
+
 func TestMain(m *testing.M) {
 	// Register test flags, then parse flags.
 	handleFlags()
diff --git a/test/e2e/node_feature_discovery.go b/test/e2e/node_feature_discovery.go
index f4103f23c..090bc1283 100644
--- a/test/e2e/node_feature_discovery.go
+++ b/test/e2e/node_feature_discovery.go
@@ -18,7 +18,6 @@ package e2e
 
 import (
 	"context"
-	"flag"
 	"fmt"
 	"path/filepath"
 	"strings"
@@ -49,9 +48,6 @@ import (
 )
 
 var (
-	dockerRepo      = flag.String("nfd.repo", "registry.k8s.io/nfd/node-feature-discovery", "Docker repository to fetch image from")
-	dockerTag       = flag.String("nfd.tag", "v0.12.0", "Docker tag to use")
-	dockerImage     = fmt.Sprintf("%s:%s", *dockerRepo, *dockerTag)
 	testTolerations = []corev1.Toleration{
 		{
 			Key:    "nfd.node.kubernetes.io/fake-special-node",
@@ -216,7 +212,7 @@ var _ = SIGDescribe("Node Feature Discovery", func() {
 				// Launch nfd-master
 				By("Creating nfd master pod and nfd-master service")
 				podSpecOpts := createPodSpecOpts(
-					testpod.SpecWithContainerImage(dockerImage),
+					testpod.SpecWithContainerImage(dockerImage()),
 					testpod.SpecWithTolerations(testTolerations),
 					testpod.SpecWithContainerExtraArgs("-enable-taints"),
 				)
@@ -265,7 +261,7 @@ var _ = SIGDescribe("Node Feature Discovery", func() {
 					By("Creating a nfd worker pod")
 					podSpecOpts := createPodSpecOpts(
 						testpod.SpecWithRestartPolicy(corev1.RestartPolicyNever),
-						testpod.SpecWithContainerImage(dockerImage),
+						testpod.SpecWithContainerImage(dockerImage()),
 						testpod.SpecWithContainerExtraArgs("-oneshot", "-label-sources=fake"),
 						testpod.SpecWithTolerations(testTolerations),
 					)
@@ -318,7 +314,7 @@ var _ = SIGDescribe("Node Feature Discovery", func() {
 
 					By("Creating nfd-worker daemonset")
 					podSpecOpts := createPodSpecOpts(
-						testpod.SpecWithContainerImage(dockerImage),
+						testpod.SpecWithContainerImage(dockerImage()),
 						testpod.SpecWithTolerations(testTolerations),
 					)
 					workerDS := testds.NFDWorker(podSpecOpts...)
@@ -448,7 +444,7 @@ var _ = SIGDescribe("Node Feature Discovery", func() {
 
 					By("Creating nfd-worker daemonset with configmap mounted")
 					podSpecOpts := createPodSpecOpts(
-						testpod.SpecWithContainerImage(dockerImage),
+						testpod.SpecWithContainerImage(dockerImage()),
 						testpod.SpecWithConfigMap(cm1.Name, filepath.Join(custom.Directory, "cm1")),
 						testpod.SpecWithConfigMap(cm2.Name, filepath.Join(custom.Directory, "cm2")),
 						testpod.SpecWithTolerations(testTolerations),
@@ -511,7 +507,7 @@ core:
 
 					By("Creating nfd-worker daemonset")
 					podSpecOpts := createPodSpecOpts(
-						testpod.SpecWithContainerImage(dockerImage),
+						testpod.SpecWithContainerImage(dockerImage()),
 						testpod.SpecWithConfigMap(cm.Name, "/etc/kubernetes/node-feature-discovery"),
 						testpod.SpecWithTolerations(testTolerations),
 					)
diff --git a/test/e2e/topology_updater.go b/test/e2e/topology_updater.go
index 8afd1399b..d63bca073 100644
--- a/test/e2e/topology_updater.go
+++ b/test/e2e/topology_updater.go
@@ -115,7 +115,7 @@ var _ = SIGDescribe("Node Feature Discovery topology updater", func() {
 			kcfg := cfg.GetKubeletConfig()
 			By(fmt.Sprintf("Using config (%#v)", kcfg))
 
-			podSpecOpts := []testpod.SpecOption{testpod.SpecWithContainerImage(dockerImage)}
+			podSpecOpts := []testpod.SpecOption{testpod.SpecWithContainerImage(dockerImage())}
 			topologyUpdaterDaemonSet = testds.NFDTopologyUpdater(kcfg, podSpecOpts...)
 		})
 
@@ -281,7 +281,7 @@ excludeList:
 			By(fmt.Sprintf("Using config (%#v)", kcfg))
 
 			podSpecOpts := []testpod.SpecOption{
-				testpod.SpecWithContainerImage(dockerImage),
+				testpod.SpecWithContainerImage(dockerImage()),
 				testpod.SpecWithConfigMap(cm.Name, "/etc/kubernetes/node-feature-discovery"),
 			}
 			topologyUpdaterDaemonSet = testds.NFDTopologyUpdater(kcfg, podSpecOpts...)