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 a94cb1926ab CAMEL-20722 - initial step to increase timeout (test fail
often without this)
a94cb1926ab is described below
commit a94cb1926abbc0d6cf5530e4820673fee8f4dd16
Author: Jang-Vijay Singh <jvs...@gmail.com>
AuthorDate: Wed May 1 13:32:23 2024 +0100
CAMEL-20722 - initial step to increase timeout (test fail often without
this)
This is only an initial step to improve this set of related tests. On
development machines and build servers, a higher timeout is desirable
(other tests in this project already use a timeout of 10 seconds)
---
.../integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java | 2 +-
.../KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT.java | 2 +-
.../KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java | 2 +-
.../KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java
index 992f4579b23..6e0bbc9e8e0 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java
@@ -98,7 +98,7 @@ class KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT
extends BaseKafkaTestSup
contextExtension.getContext().getRouteController().startRoute(ROUTE_ID);
Awaitility.await()
- .atMost(3, TimeUnit.SECONDS)
+ .atMost(10, TimeUnit.SECONDS) // changed to 10 sec for
CAMEL-20722
.until(() -> to.getExchanges().size() > 3);
to.assertIsSatisfied(3000);
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 3fbf3f02028..d7fb16d8016 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
@@ -96,7 +96,7 @@ class
KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT extends BaseExclu
contextExtension.getContext().getRouteController().startRoute(ROUTE_ID);
Awaitility.await()
- .atMost(3, TimeUnit.SECONDS)
+ .atMost(10, TimeUnit.SECONDS) // changed to 10 sec for
CAMEL-20722
.until(() -> errorPayloads.size() > 3);
to.assertIsSatisfied();
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java
index 7ffc434ad50..88b8a5fbb3b 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java
@@ -99,7 +99,7 @@ class KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT
extends BaseKafkaT
contextExtension.getContext().getRouteController().startRoute(ROUTE_ID);
Awaitility.await()
- .atMost(3, TimeUnit.SECONDS)
+ .atMost(10, TimeUnit.SECONDS) // changed to 10 sec for
CAMEL-20722
.until(() -> to.getExchanges().size() > 5);
to.assertIsSatisfied(3000);
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java
index 32df79bb2ae..fb250ab972a 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java
@@ -95,7 +95,7 @@ class
KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT extends BaseK
contextExtension.getContext().getRouteController().startRoute(ROUTE_ID);
Awaitility.await()
- .atMost(3, TimeUnit.SECONDS)
+ .atMost(10, TimeUnit.SECONDS) // changed to 10 sec for
CAMEL-20722
.until(() -> to.getExchanges().size() > 7);
assertFalse(to.getExchanges().stream()
