You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2024/05/09 12:24:39 UTC
(camel) branch main updated: CAMEL-20722: prevent certain camel-kafka tests from running on Power and s390x
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 82190343cbf CAMEL-20722: prevent certain camel-kafka tests from running on Power and s390x
82190343cbf is described below
commit 82190343cbf253bd3122788ce20563c2f4445c19
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu May 9 13:53:58 2024 +0200
CAMEL-20722: prevent certain camel-kafka tests from running on Power and s390x
These tests are constantly flaky on those platforms in our CI, although they may run fine on environments less resource-constrained
---
.../KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java | 5 ++---
.../kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java | 6 +++++-
.../integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java | 5 +++++
.../kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java | 5 ++---
.../KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT.java | 5 ++---
.../KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java | 5 ++---
...afkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java | 5 ++---
.../KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java | 5 ++---
8 files changed, 22 insertions(+), 19 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 e7d7e682b7b..26cc15816b6 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
@@ -48,9 +48,8 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch64", "s390x", "x86", "x86_64" },
- disabledReason = "This test does not run reliably on ppc64le")
-
+ architectures = { "amd64", "aarch64" },
+ disabledReason = "This test does not run reliably on some platforms")
class KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT extends BaseKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstErrorOff";
public static final String TOPIC = "breakOnFirstErrorOff";
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java
index 1307a84fb00..96ab7c16823 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java
@@ -32,6 +32,8 @@ import org.apache.kafka.clients.admin.NewTopic;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.awaitility.Awaitility;
import org.junit.jupiter.api.*;
+import org.junit.jupiter.api.condition.EnabledOnOs;
+import org.junit.jupiter.api.condition.OS;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -44,7 +46,9 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
*
*/
@Tags({ @Tag("breakOnFirstError") })
-
+@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
+ architectures = { "amd64", "aarch64" },
+ disabledReason = "This test does not run reliably on some platforms")
class KafkaBreakOnFirstErrorReleaseResourcesIT extends BaseKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstError-20563";
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java
index c6a95252638..d70f8c482cd 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java
@@ -41,6 +41,8 @@ import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
+import org.junit.jupiter.api.condition.EnabledOnOs;
+import org.junit.jupiter.api.condition.OS;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -55,6 +57,9 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
@Tags({ @Tag("breakOnFirstError") })
@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*",
disabledReason = "Multiple problems: unreliable and slow (see CAMEL-20680)")
+@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
+ architectures = { "amd64", "aarch64" },
+ disabledReason = "This test does not run reliably on some platforms")
class KafkaBreakOnFirstErrorReplayOldMessagesIT extends BaseKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstError-20044";
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 99d2e2877e3..78b3a9900b9 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
@@ -52,9 +52,8 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch64", "s390x", "x86", "x86_64" },
- disabledReason = "This test does not run reliably on ppc64le")
-
+ architectures = { "amd64", "aarch64" },
+ disabledReason = "This test does not run reliably on some platforms")
class KafkaBreakOnFirstErrorSeekIssueIT extends BaseExclusiveKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstError-19894";
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 c24fe080708..17abc4e5560 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
@@ -48,9 +48,8 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch64", "s390x", "x86", "x86_64" },
- disabledReason = "This test does not run reliably on ppc64le")
-
+ architectures = { "amd64", "aarch64" },
+ disabledReason = "This test does not run reliably on some platforms")
class KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT extends BaseExclusiveKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstErrorBatchIT";
public static final String TOPIC = "breakOnFirstErrorBatchIT";
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 e150e104381..2f95c6f45aa 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
@@ -48,9 +48,8 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch64", "s390x", "x86", "x86_64" },
- disabledReason = "This test does not run reliably on ppc64le")
-
+ architectures = { "amd64", "aarch64" },
+ disabledReason = "This test does not run reliably on some platforms")
class KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT extends BaseKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstErrorBatchOnExceptionIT";
public static final String TOPIC = "breakOnFirstErrorBatchOnExceptionIT";
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 1eb086c568b..f240a7ede0c 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
@@ -52,9 +52,8 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch64", "s390x", "x86", "x86_64" },
- disabledReason = "This test does not run reliably on ppc64le")
-
+ architectures = { "amd64", "aarch64" },
+ disabledReason = "This test does not run reliably on some platforms")
class KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT extends BaseKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstErrorBatchRetryIT";
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java
index 3a53def43a0..e8868264dc9 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java
@@ -48,9 +48,8 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch64", "s390x", "x86", "x86_64" },
- disabledReason = "This test does not run reliably on ppc64le")
-
+ architectures = { "amd64", "aarch64" },
+ disabledReason = "This test does not run reliably on some platforms")
class KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT extends BaseKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstErrorBatchITSyncCommitManager";
public static final String TOPIC = "breakOnFirstErrorBatchITSyncCommitManager";