Fix for a failing Kafka operator job

quarkus-qe · Oct 13, 2022 · e8d2c16 · e8d2c16
1 parent 9a42e79
commit e8d2c16
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/quarkus-test-core/src/main/java/io/quarkus/test/bootstrap/BaseService.java b/quarkus-test-core/src/main/java/io/quarkus/test/bootstrap/BaseService.java
@@ -13,6 +13,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.ServiceLoader;
+import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.Supplier;
 import java.util.stream.Stream;
 
@@ -41,6 +42,9 @@ public class BaseService<T extends Service> implements Service {
     private final Map<String, String> properties = new HashMap<>();
     private final List<Runnable> futureProperties = new LinkedList<>();
 
+    //TODO workaround for https://github.com/fabric8io/kubernetes-client/issues/4491
+    private final AtomicBoolean isStopped = new AtomicBoolean(false);
+
     private ManagedResourceBuilder managedResourceBuilder;
     private ManagedResource managedResource;
     private String serviceName;
@@ -206,7 +210,7 @@ public void start() {
      */
     @Override
     public void stop() {
-        if (!isRunning()) {
+        if (isStopped.get() || !isRunning()) {
             return;
         }
 
@@ -215,6 +219,7 @@ public void stop() {
         managedResource.stop();
 
         Log.info(this, "Service stopped (%s)", getDisplayName());
+        isStopped.set(true);
     }
 
     /**