Skip to content

Commit 7328817

Browse files
authored
fix: Issue for "Operator Couldn't start source ..." (#1070)
1 parent 7d0c2ba commit 7328817

File tree

3 files changed

+4
-6
lines changed

3 files changed

+4
-6
lines changed

operator-framework-junit5/src/main/java/io/javaoperatorsdk/operator/junit/OperatorExtension.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@
44
import java.time.Duration;
55
import java.util.ArrayList;
66
import java.util.List;
7-
import java.util.concurrent.TimeUnit;
87
import java.util.function.Consumer;
98
import java.util.stream.Collectors;
109
import java.util.stream.Stream;
@@ -100,8 +99,11 @@ protected void before(ExtensionContext context) {
10099
try (InputStream is = getClass().getResourceAsStream(path)) {
101100
final var crd = kubernetesClient.load(is);
102101
crd.createOrReplace();
103-
crd.waitUntilReady(2, TimeUnit.SECONDS);
102+
Thread.sleep(2000); // readiness is not applicable for CRD, just wait a little
104103
LOGGER.debug("Applied CRD with name: {}", config.getResourceTypeName());
104+
} catch (InterruptedException ex) {
105+
LOGGER.error("Interrupted.", ex);
106+
Thread.currentThread().interrupt();
105107
} catch (Exception ex) {
106108
throw new IllegalStateException("Cannot apply CRD yaml: " + path, ex);
107109
}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/event/EventSourceTestCustomReconciler.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
import java.util.concurrent.atomic.AtomicInteger;
44

5-
import io.javaoperatorsdk.operator.ReconcilerUtils;
65
import io.javaoperatorsdk.operator.api.reconciler.*;
76
import io.javaoperatorsdk.operator.api.reconciler.ControllerConfiguration;
87
import io.javaoperatorsdk.operator.support.TestExecutionInfoProvider;
@@ -12,8 +11,6 @@ public class EventSourceTestCustomReconciler
1211
implements Reconciler<EventSourceTestCustomResource>,
1312
TestExecutionInfoProvider {
1413

15-
public static final String FINALIZER_NAME =
16-
ReconcilerUtils.getDefaultFinalizerName(EventSourceTestCustomResource.class);
1714
public static final int TIMER_PERIOD = 500;
1815
private final AtomicInteger numberOfExecutions = new AtomicInteger(0);
1916

operator-framework/src/test/java/io/javaoperatorsdk/operator/support/TestUtils.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@ public class TestUtils {
1212

1313
public static final String TEST_CUSTOM_RESOURCE_PREFIX = "test-custom-resource-";
1414
public static final String TEST_CUSTOM_RESOURCE_NAME = "test-custom-resource";
15-
public static final String TEST_NAMESPACE = "java-operator-sdk-int-test";
1615

1716
public static TestCustomResource testCustomResource() {
1817
return testCustomResource(UUID.randomUUID().toString());

0 commit comments

Comments
 (0)