From 7e32c2d99d7646a575414317595609ae608bc6e7 Mon Sep 17 00:00:00 2001 From: "Otavio R. Piske" Date: Sat, 6 Jan 2024 12:26:17 +0100 Subject: [PATCH] (chores) camel-kafka: disable flaky tests on ppc64le Signed-off-by: Otavio R. Piske --- .../KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java | 5 +++++ .../KafkaBreakOnFirstErrorReplayOldMessagesIT.java | 5 +++++ .../kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java | 5 +++++ ...BreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT.java | 5 +++++ ...kaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java | 5 +++++ ...akOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java | 5 +++++ .../kafka/integration/health/KafkaConsumerHealthCheckIT.java | 5 +++++ 7 files changed, 35 insertions(+) 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 6ad7ee0a6f5b9..bc3ad03f37e11 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 @@ -35,6 +35,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.EnabledOnOs; +import org.junit.jupiter.api.condition.OS; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -45,6 +47,9 @@ * KafkaManualCommit and NOOP Commit Manager */ @Tags({ @Tag("breakOnFirstError") }) +@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS }, + architectures = { "amd64", "aarch_64", "s390x" }, + disabledReason = "This test does not run reliably on ppc64le") class KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT extends BaseEmbeddedKafkaTestSupport { 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/KafkaBreakOnFirstErrorReplayOldMessagesIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java index 4f46bf21f8a61..7f4018476676b 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 @@ -40,6 +40,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.EnabledOnOs; +import org.junit.jupiter.api.condition.OS; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -52,6 +54,9 @@ * mimics the reproduction of the problem in https://github.com/CodeSmell/CamelKafkaOffset */ @Tags({ @Tag("breakOnFirstError") }) +@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS }, + architectures = { "amd64", "aarch_64", "s390x" }, + disabledReason = "This test does not run reliably on ppc64le") class KafkaBreakOnFirstErrorReplayOldMessagesIT extends BaseEmbeddedKafkaTestSupport { 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 c2a17a3c5c4bb..6a0069201aa39 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 @@ -37,6 +37,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.EnabledOnOs; +import org.junit.jupiter.api.condition.OS; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -49,6 +51,9 @@ * mimics the reproduction of the problem in https://github.com/Krivda/camel-bug-reproduction */ @Tags({ @Tag("breakOnFirstError") }) +@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS }, + architectures = { "amd64", "aarch_64", "s390x" }, + disabledReason = "This test does not run reliably on ppc64le") class KafkaBreakOnFirstErrorSeekIssueIT extends BaseEmbeddedKafkaTestSupport { public static final String ROUTE_ID = "breakOnFirstError-19894"; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT.java index 498f7696da53b..c02b3524a0f2a 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT.java @@ -35,6 +35,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.EnabledOnOs; +import org.junit.jupiter.api.condition.OS; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -45,6 +47,9 @@ * Camel to handle when to commit an offset */ @Tags({ @Tag("breakOnFirstError") }) +@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS }, + architectures = { "amd64", "aarch_64", "s390x" }, + disabledReason = "This test does not run reliably on ppc64le") class KafkaBreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT extends BaseEmbeddedKafkaTestSupport { 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 aa06e402361aa..b0e719751a2e9 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 @@ -35,6 +35,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.EnabledOnOs; +import org.junit.jupiter.api.condition.OS; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -45,6 +47,9 @@ * Camel default to use NOOP Commit Manager this means the route implementation MUST manage all offset commits */ @Tags({ @Tag("breakOnFirstError") }) +@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS }, + architectures = { "amd64", "aarch_64", "s390x" }, + disabledReason = "This test does not run reliably on ppc64le") class KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT extends BaseEmbeddedKafkaTestSupport { 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 c6e6508ed9d2b..504a34feb1319 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 @@ -35,6 +35,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.EnabledOnOs; +import org.junit.jupiter.api.condition.OS; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -49,6 +51,9 @@ * will demonstrate how to retry */ @Tags({ @Tag("breakOnFirstError") }) +@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS }, + architectures = { "amd64", "aarch_64", "s390x" }, + disabledReason = "This test does not run reliably on ppc64le") class KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT extends BaseEmbeddedKafkaTestSupport { public static final String ROUTE_ID = "breakOnFirstErrorBatchRetryIT"; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerHealthCheckIT.java index 47292f4405bbf..73b95b0eb07bb 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerHealthCheckIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerHealthCheckIT.java @@ -44,6 +44,8 @@ import org.junit.jupiter.api.TestInstance; import org.junit.jupiter.api.TestMethodOrder; import org.junit.jupiter.api.Timeout; +import org.junit.jupiter.api.condition.EnabledOnOs; +import org.junit.jupiter.api.condition.OS; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -56,6 +58,9 @@ @TestInstance(TestInstance.Lifecycle.PER_CLASS) @TestMethodOrder(MethodOrderer.OrderAnnotation.class) @Tags({ @Tag("health") }) +@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS }, + architectures = { "amd64", "aarch_64", "s390x" }, + disabledReason = "This test does not run reliably on ppc64le") public class KafkaConsumerHealthCheckIT extends KafkaHealthCheckTestSupport { public static final String TOPIC = "test-health"; public static final String SKIPPED_HEADER_KEY = "CamelSkippedHeader";