(camel) branch main updated: CAMEL-20722 - increase timeout specifically due to ppc64le

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 92f1b946367 CAMEL-20722 - increase timeout specifically due to ppc64le
92f1b946367 is described below

commit 92f1b946367b2d25453acd25876054d4ee5d18fc
Author: Jang-Vijay Singh <jvs...@gmail.com>
AuthorDate: Tue Jun 11 07:34:14 2024 +0100

    CAMEL-20722 - increase timeout specifically due to ppc64le
---
 .../integration/KafkaBreakOnFirstErrorSeekIssueIT.java      |  6 +++---
 ...BreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT.java | 13 +++++++++++--
 2 files changed, 14 insertions(+), 5 deletions(-)

diff --git 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java
 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java
index 33db5d1e3c7..023d43ffa12 100644
--- 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java
+++ 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java
@@ -81,7 +81,7 @@ class KafkaBreakOnFirstErrorSeekIssueIT extends 
BaseKafkaTestSupport {
 
         // This wait is necessary to ensure that required number of partitions 
are actually created
         Awaitility.await()
-                .timeout(20, TimeUnit.SECONDS)
+                .timeout(180, TimeUnit.SECONDS)
                 .pollDelay(5, TimeUnit.SECONDS)
                 .untilAsserted(() -> 
assertTrue(r.numPartitions(TOPIC).isDone()));
 
@@ -127,8 +127,8 @@ class KafkaBreakOnFirstErrorSeekIssueIT extends 
BaseKafkaTestSupport {
 
         // let test run for awhile
         Awaitility.await()
-                .timeout(30, TimeUnit.SECONDS)
-                .pollDelay(8, TimeUnit.SECONDS)
+                .timeout(180, TimeUnit.SECONDS)
+                .pollDelay(5, TimeUnit.SECONDS)
                 .untilAsserted(() -> assertTrue(true));
 
         // the replaying of the message with an error
diff --git 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT.java
 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT.java
index 045968b41a4..9d917bd1025 100644
--- 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT.java
+++ 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT.java
@@ -28,6 +28,7 @@ import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.kafka.MockConsumerInterceptor;
 import org.apache.camel.component.kafka.testutil.CamelKafkaUtil;
 import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.kafka.clients.admin.DeleteTopicsResult;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.Uuid;
 import org.awaitility.Awaitility;
@@ -42,6 +43,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
 
 /**
  * this will test basic breakOnFirstError functionality uses allowManualCommit 
and set Sync Commit Manager this allows
@@ -78,7 +80,14 @@ class 
KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT extends BaseKafka
             producer.close();
         }
         // clean all test topics
-        kafkaAdminClient.deleteTopics(Collections.singletonList(TOPIC)).all();
+        DeleteTopicsResult r = 
kafkaAdminClient.deleteTopics(Collections.singletonList(TOPIC));
+
+        // wait added to ensure the topic is actually deleted, and avoid 
chance of clash in unrelated tests
+        Awaitility.await()
+                .timeout(180, TimeUnit.SECONDS)
+                .pollDelay(3, TimeUnit.SECONDS)
+                .untilAsserted(() -> assertTrue(r.all().isDone()));
+
     }
 
     /**
@@ -100,7 +109,7 @@ class 
KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT extends BaseKafka
         
contextExtension.getContext().getRouteController().startRoute(ROUTE_ID);
 
         Awaitility.await()
-                .atMost(20, TimeUnit.SECONDS) // changed to 20 sec for 
CAMEL-20722
+                .atMost(180, TimeUnit.SECONDS) // increased to 180 sec for 
CAMEL-20722 due to failure on ppc64le
                 .pollDelay(5, TimeUnit.SECONDS)
                 .until(() -> errorPayloads.size() > 3);