From b3b5fd2d7bfd781f1cf7ed923e82c5738fbdd270 Mon Sep 17 00:00:00 2001 From: Dennis-Mircea Ciupitu Date: Fri, 15 May 2026 15:23:11 +0300 Subject: [PATCH] fix: invoke ConfigurationServiceOverrider consumer only once in Operator constructor Signed-off-by: Dennis-Mircea Ciupitu --- .../io/javaoperatorsdk/operator/Operator.java | 17 +++-------------- 1 file changed, 3 insertions(+), 14 deletions(-) diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java index 0cfe0e997a..fa8b4620bf 100644 --- a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java +++ b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java @@ -122,21 +122,10 @@ private void init(ConfigurationService configurationService, boolean allowDeferr */ protected ConfigurationService initConfigurationService( KubernetesClient client, Consumer overrider) { - // initialize the client if the user didn't provide one - if (client == null) { - var configurationService = ConfigurationService.newOverriddenConfigurationService(overrider); - client = configurationService.getKubernetesClient(); + if (client != null) { + Consumer bindClient = o -> o.withKubernetesClient(client); + overrider = overrider == null ? bindClient : overrider.andThen(bindClient); } - - final var kubernetesClient = client; - - // override the configuration service to use the same client - if (overrider != null) { - overrider = overrider.andThen(o -> o.withKubernetesClient(kubernetesClient)); - } else { - overrider = o -> o.withKubernetesClient(kubernetesClient); - } - return ConfigurationService.newOverriddenConfigurationService(overrider); }