Fix: define default namespace cache only if watchNamespace is set (#860)

spotify · Jan 13, 2025 · 6a09135 · 6a09135
1 parent fdad12d
commit 6a09135
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/main.go b/main.go
@@ -72,12 +72,18 @@ func main() {
 		WithName("FlinkCluster")
 	ctrl.SetLogger(logger)
 
+	defaultNamespaces := make(map[string]cache.Config)
+	if *watchNamespace != "" {
+		setupLog.Info("Watching custom resources in the namespace", "namespace", *watchNamespace)
+		defaultNamespaces[*watchNamespace] = cache.Config{}
+	}
+
 	mgr, err := ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{
 		Scheme:         scheme,
 		Metrics:        metricsserver.Options{BindAddress: *metricsAddr},
 		LeaderElection: *enableLeaderElection,
 		Cache: cache.Options{
-			DefaultNamespaces: map[string]cache.Config{*watchNamespace: {}},
+			DefaultNamespaces: defaultNamespaces,
 		},
 		LeaderElectionID: *leaderElectionID,
 	})