This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 0e6a68aedcf NIFI-16093 Wait for Couchbase Readiness in
AbstractCouchbaseIT to stabilize integration tests (#11409)
0e6a68aedcf is described below
commit 0e6a68aedcffad0154e830691acbee8dd76bf9d4
Author: Pierre Villard <[email protected]>
AuthorDate: Wed Jul 8 19:48:54 2026 +0200
NIFI-16093 Wait for Couchbase Readiness in AbstractCouchbaseIT to stabilize
integration tests (#11409)
Signed-off-by: David Handermann <[email protected]>
---
.../nifi/processors/couchbase/integration/AbstractCouchbaseIT.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git
a/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/AbstractCouchbaseIT.java
b/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/AbstractCouchbaseIT.java
index edd0725f2d0..28e1ffb8dbf 100644
---
a/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/AbstractCouchbaseIT.java
+++
b/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/AbstractCouchbaseIT.java
@@ -16,6 +16,7 @@
*/
package org.apache.nifi.processors.couchbase.integration;
+import com.couchbase.client.java.Cluster;
import org.apache.nifi.reporting.InitializationException;
import org.apache.nifi.services.couchbase.StandardCouchbaseConnectionService;
import org.apache.nifi.util.TestRunner;
@@ -24,6 +25,8 @@ import org.junit.jupiter.api.BeforeAll;
import org.testcontainers.couchbase.BucketDefinition;
import org.testcontainers.couchbase.CouchbaseContainer;
+import java.time.Duration;
+
import static
org.apache.nifi.services.couchbase.StandardCouchbaseConnectionService.CONNECTION_STRING;
import static
org.apache.nifi.services.couchbase.StandardCouchbaseConnectionService.PASSWORD;
import static
org.apache.nifi.services.couchbase.StandardCouchbaseConnectionService.USERNAME;
@@ -59,6 +62,9 @@ public class AbstractCouchbaseIT {
@BeforeAll
public static void start() {
container.start();
+ try (Cluster cluster =
Cluster.connect(container.getConnectionString(), container.getUsername(),
container.getPassword())) {
+
cluster.bucket(TEST_BUCKET_NAME).waitUntilReady(Duration.ofSeconds(60));
+ }
}
@AfterAll
