Enable several disabled tests, remove others

[fedinskiy]

Summary

• Enable tests, which were disabled due to issues, which are now fixed (one of them required changes)
• Remove a test which was disabled since Quarkus 2 era

Please select the relevant options.

• Bug fix (non-breaking change which fixes an issue)
• Dependency update
• Refactoring
• Backport
• New scenario (non-breaking change which adds functionality)
• This change requires a documentation update
• This change requires execution against OCP (use run tests phrase in comment)

Checklist:

• Methods and classes used in PR scenarios are meaningful
• Commits are well encapsulated and follow the best practices

[rsvoboda]

@fedinskiy formatting check didn't pass

Several DisabledOnAarch64Native were removed, do you have run of the branch in in the lab with aarch64? fyi @mjurc
(@mjurc shouldn't we have aarch64 triggered by "run tests" phrase, we should have QQE for it)

This PR seems to be suitable for "run tests" phrase

[fedinskiy]

@rsvoboda
formatting was fixed, aarch64 running is a planned next step. I do not think, that we can run aarc64 tests automatically, but would be glad to be proved wrong

[rsvoboda]

You need to run them on your own and you should as you are enabling tests specifically for that platform

[michalvavrik]

@fedinskiy I don't need a proof (link, job run etc.), but I need you to check that enabled tests will suceed on Aarch64, could you check please?

[github-actions]

Following jobs contain at least one flaky test:

• PR - Linux - JVM build - Latest Version

Run summary: https://github.com/quarkus-qe/quarkus-test-suite/actions/runs/11839134584?pr=2191

Flaky tests:

---

io.quarkus.ts.messaging.kafka.reactive.streams.KafkaGratefulShutdownIT.testConnection

• Failure message: Assertion condition defined as a Lambda expression in io.quarkus.test.utils.LogsVerifier Log does not contain any of '[ave]'. Full logs: [__ ____ __ _____ ___ __ ____ ______ , --/ __ \/ / / / _ | / _ \/ //_/ / / / __/ , -/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \ , --\___\_\____/_/ |_/_/|_/_/|_|\____/___/ , 15:05:14,682 SRMSG18229: Configured topics for channel 'slow': [slow], 15:05:14,698 SRMSG18214: Key deserializer omitted, using String as default, 15:05:14,698 SRMSG18234: Auto-commit disabled for channel slow, 15:05:14,878 SRMSG18240: 'throttled' commit strategy used for channel 'slow', 15:05:14,878 SRMSG18232: Will commit for group 'kafka-streams-reactive-messaging' every 5000 milliseconds., 15:05:14,879 SRMSG18236: Will mark throttled commit strategy for group 'kafka-streams-reactive-messaging' as unhealthy if records go more than 60000 milliseconds without being processed., 15:05:14,916 SRMSG18248: Key serializer omitted, using String as default, 15:05:14,949 SRMSG18258: Kafka producer kafka-producer-slow-topic, connected to Kafka brokers 'localhost:32781', is configured to write records to 'slow', 15:05:14,998 SRMSG18257: Kafka consumer kafka-consumer-slow, connected to Kafka brokers 'localhost:32781', belongs to the 'kafka-streams-reactive-messaging' consumer group and is configured to poll records from [slow], 15:05:15,008 No Topology producer; Kafka Streams will not be started, 15:05:15,119 kafka-streams-reactive-messaging 1.0.0-SNAPSHOT on JVM (powered by Quarkus 999-SNAPSHOT) started in 1.342s. Listening on: http://0.0.0.0:1104, 15:05:15,119 Profile prod activated. , 15:05:15,119 Installed features: [cdi, kafka-client, kafka-streams, messaging, messaging-kafka, resteasy, resteasy-jsonb, smallrye-context-propagation, vertx], 15:05:15,231 [Consumer clientId=kafka-consumer-slow, groupId=kafka-streams-reactive-messaging] Error while fetching metadata with correlation id 2 : {slow=UNKNOWN_TOPIC_OR_PARTITION}, 15:05:18,803 SRMSG18209: Sending message org.eclipse.microprofile.reactive.messaging.Message$5@1a7feec3 from channel 'slow-topic' to Kafka topic 'slow', 15:05:18,944 SRMSG18211: Message org.eclipse.microprofile.reactive.messaging.Message$5@1a7feec3 from channel 'slow-topic' sent successfully to Kafka topic-partition 'slow-0', with offset 0] ==> expected: <true> but was: <false> within 30 seconds.
• Failed in jobs:
  • PR - Linux - JVM build - Latest Version

Failure stacktrace

org.awaitility.core.ConditionTimeoutException: Assertion condition defined as a Lambda expression in io.quarkus.test.utils.LogsVerifier Log does not contain any of '[ave]'. Full logs: [__  ____  __  _____   ___  __ ____  ______ ,  --/ __ \/ / / / _ | / _ \/ //_/ / / / __/ ,  -/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \   , --\___\_\____/_/ |_/_/|_/_/|_|\____/___/   , 15:05:14,682 SRMSG18229: Configured topics for channel 'slow': [slow], 15:05:14,698 SRMSG18214: Key deserializer omitted, using String as default, 15:05:14,698 SRMSG18234: Auto-commit disabled for channel slow, 15:05:14,878 SRMSG18240: 'throttled' commit strategy used for channel 'slow', 15:05:14,878 SRMSG18232: Will commit for group 'kafka-streams-reactive-messaging' every 5000 milliseconds., 15:05:14,879 SRMSG18236: Will mark throttled commit strategy for group 'kafka-streams-reactive-messaging' as unhealthy if records go more than 60000 milliseconds without being processed., 15:05:14,916 SRMSG18248: Key serializer omitted, using String as default, 15:05:14,949 SRMSG18258: Kafka producer kafka-producer-slow-topic, connected to Kafka brokers 'localhost:32781', is configured to write records to 'slow', 15:05:14,998 SRMSG18257: Kafka consumer kafka-consumer-slow, connected to Kafka brokers 'localhost:32781', belongs to the 'kafka-streams-reactive-messaging' consumer group and is configured to poll records from [slow], 15:05:15,008 No Topology producer; Kafka Streams will not be started, 15:05:15,119 kafka-streams-reactive-messaging 1.0.0-SNAPSHOT on JVM (powered by Quarkus 999-SNAPSHOT) started in 1.342s. Listening on: http://0.0.0.0:1104, 15:05:15,119 Profile prod activated. , 15:05:15,119 Installed features: [cdi, kafka-client, kafka-streams, messaging, messaging-kafka, resteasy, resteasy-jsonb, smallrye-context-propagation, vertx], 15:05:15,231 [Consumer clientId=kafka-consumer-slow, groupId=kafka-streams-reactive-messaging] Error while fetching metadata with correlation id 2 : {slow=UNKNOWN_TOPIC_OR_PARTITION}, 15:05:18,803 SRMSG18209: Sending message org.eclipse.microprofile.reactive.messaging.Message$5@1a7feec3 from channel 'slow-topic' to Kafka topic 'slow', 15:05:18,944 SRMSG18211: Message org.eclipse.microprofile.reactive.messaging.Message$5@1a7feec3 from channel 'slow-topic' sent successfully to Kafka topic-partition 'slow-0', with offset 0] ==> expected: <true> but was: <false> within 30 seconds.
	at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
	at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:119)
	at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:31)
	at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1006)
	at org.awaitility.core.ConditionFactory.untilAsserted(ConditionFactory.java:790)
	at io.quarkus.test.utils.AwaitilityUtils.untilAsserted(AwaitilityUtils.java:134)
	at io.quarkus.test.utils.AwaitilityUtils.untilAsserted(AwaitilityUtils.java:124)
	at io.quarkus.test.utils.LogsVerifier.assertContains(LogsVerifier.java:28)
	at io.quarkus.ts.messaging.kafka.reactive.streams.KafkaGratefulShutdownIT.testConnection(KafkaGratefulShutdownIT.java:72)
	at java.base/java.lang.reflect.Method.invoke(Method.java:569)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
Caused by: org.opentest4j.AssertionFailedError: Log does not contain any of '[ave]'. Full logs: [__  ____  __  _____   ___  __ ____  ______ ,  --/ __ \/ / / / _ | / _ \/ //_/ / / / __/ ,  -/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \   , --\___\_\____/_/ |_/_/|_/_/|_|\____/___/   , 15:05:14,682 SRMSG18229: Configured topics for channel 'slow': [slow], 15:05:14,698 SRMSG18214: Key deserializer omitted, using String as default, 15:05:14,698 SRMSG18234: Auto-commit disabled for channel slow, 15:05:14,878 SRMSG18240: 'throttled' commit strategy used for channel 'slow', 15:05:14,878 SRMSG18232: Will commit for group 'kafka-streams-reactive-messaging' every 5000 milliseconds., 15:05:14,879 SRMSG18236: Will mark throttled commit strategy for group 'kafka-streams-reactive-messaging' as unhealthy if records go more than 60000 milliseconds without being processed., 15:05:14,916 SRMSG18248: Key serializer omitted, using String as default, 15:05:14,949 SRMSG18258: Kafka producer kafka-producer-slow-topic, connected to Kafka brokers 'localhost:32781', is configured to write records to 'slow', 15:05:14,998 SRMSG18257: Kafka consumer kafka-consumer-slow, connected to Kafka brokers 'localhost:32781', belongs to the 'kafka-streams-reactive-messaging' consumer group and is configured to poll records from [slow], 15:05:15,008 No Topology producer; Kafka Streams will not be started, 15:05:15,119 kafka-streams-reactive-messaging 1.0.0-SNAPSHOT on JVM (powered by Quarkus 999-SNAPSHOT) started in 1.342s. Listening on: http://0.0.0.0:1104, 15:05:15,119 Profile prod activated. , 15:05:15,119 Installed features: [cdi, kafka-client, kafka-streams, messaging, messaging-kafka, resteasy, resteasy-jsonb, smallrye-context-propagation, vertx], 15:05:15,231 [Consumer clientId=kafka-consumer-slow, groupId=kafka-streams-reactive-messaging] Error while fetching metadata with correlation id 2 : {slow=UNKNOWN_TOPIC_OR_PARTITION}, 15:05:18,803 SRMSG18209: Sending message org.eclipse.microprofile.reactive.messaging.Message$5@1a7feec3 from channel 'slow-topic' to Kafka topic 'slow', 15:05:18,944 SRMSG18211: Message org.eclipse.microprofile.reactive.messaging.Message$5@1a7feec3 from channel 'slow-topic' sent successfully to Kafka topic-partition 'slow-0', with offset 0] ==> expected: <true> but was: <false>
	at io.quarkus.test.utils.LogsVerifier.lambda$assertContains$0(LogsVerifier.java:30)
	at org.awaitility.core.AssertionCondition.lambda$new$0(AssertionCondition.java:53)
	at org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:248)
	at org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:235)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:840)

---

[michalvavrik]

run tests

[michalvavrik]

Changes LGTM, thank you. Of enabled Aarch64, following needs to be checked:

• Kafka snappy conversion fails on native aarch64 for missing native library quarkusio/quarkus#43801
• https://issues.redhat.com/browse/QUARKUS-5180

Feel free to merge it when you have done so. I have triggered OCP run, let's recheck its results as well please.

[fedinskiy]

Brotli: this works on ARM: mvn clean verify -Popenshift -Dit.test=OpenShiftBrotli4JIT -Doc.reruns=0 -pl http/http-advanced-reactive/ -Dall-modules, but requires adding native brotli library for arm. Probably this is also going to affect IBM folks, but let's solve problems, when they arise.
Kafka producer: mvn clean verify -Dopenshift -Dnative -Dit.test=OpenShiftKafkaSnappyIT -Doc.reruns=0 -pl messaging/kafka-producer/ -Dall-modules works on arm cluster, but requires starting the test from arm machine. MJ says it is expected
mvn clean verify -Dnative -Dit.test=SnappyCompressionIT -Doc.reruns=0 -pl messaging/kafka-producer/ -Dall-modules — works on arm64
mvn clean verify -Dall-modules -Dopenshift -Dnative -Dts.redhat.registry.enabled=true -Dinclude.serverless -Dts.container.registry-url=quay.io/quarkusqeteam -Dinclude.operator-scenarios -pl messaging/kafka-streams-reactive-messaging/ — works on arm
mvn clean verify -Dall-modules -pl sql-db/reactive-vanilla/ -Dit.test=DevModeMultipleReactiveSqlClientsIT — works on arm

[github-actions]

Following jobs contain at least one flaky test:

• PR - Linux - JVM build - Latest Version

Run summary: https://github.com/quarkus-qe/quarkus-test-suite/actions/runs/11855572203?pr=2191

Flaky tests:

---

io.quarkus.ts.messaging.kafka.reactive.streams.KafkaGratefulShutdownIT.testConnection

• Failure message: Assertion condition defined as a Lambda expression in io.quarkus.test.utils.LogsVerifier Log does not contain any of '[ave]'. Full logs: [__ ____ __ _____ ___ __ ____ ______ , --/ __ \/ / / / _ | / _ \/ //_/ / / / __/ , -/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \ , --\___\_\____/_/ |_/_/|_/_/|_|\____/___/ , 12:53:48,486 SRMSG18229: Configured topics for channel 'slow': [slow], 12:53:48,500 SRMSG18214: Key deserializer omitted, using String as default, 12:53:48,500 SRMSG18234: Auto-commit disabled for channel slow, 12:53:48,671 SRMSG18240: 'throttled' commit strategy used for channel 'slow', 12:53:48,672 SRMSG18232: Will commit for group 'kafka-streams-reactive-messaging' every 5000 milliseconds., 12:53:48,672 SRMSG18236: Will mark throttled commit strategy for group 'kafka-streams-reactive-messaging' as unhealthy if records go more than 60000 milliseconds without being processed., 12:53:48,708 SRMSG18248: Key serializer omitted, using String as default, 12:53:48,739 SRMSG18258: Kafka producer kafka-producer-slow-topic, connected to Kafka brokers 'localhost:32781', is configured to write records to 'slow', 12:53:48,787 SRMSG18257: Kafka consumer kafka-consumer-slow, connected to Kafka brokers 'localhost:32781', belongs to the 'kafka-streams-reactive-messaging' consumer group and is configured to poll records from [slow], 12:53:48,791 No Topology producer; Kafka Streams will not be started, 12:53:48,877 kafka-streams-reactive-messaging 1.0.0-SNAPSHOT on JVM (powered by Quarkus 999-SNAPSHOT) started in 1.271s. Listening on: http://0.0.0.0:1104, 12:53:48,877 Profile prod activated. , 12:53:48,877 Installed features: [cdi, kafka-client, kafka-streams, messaging, messaging-kafka, resteasy, resteasy-jsonb, smallrye-context-propagation, vertx], 12:53:49,003 [Consumer clientId=kafka-consumer-slow, groupId=kafka-streams-reactive-messaging] Error while fetching metadata with correlation id 2 : {slow=UNKNOWN_TOPIC_OR_PARTITION}, 12:53:52,545 SRMSG18209: Sending message org.eclipse.microprofile.reactive.messaging.Message$5@1a7d0070 from channel 'slow-topic' to Kafka topic 'slow', 12:53:52,665 SRMSG18211: Message org.eclipse.microprofile.reactive.messaging.Message$5@1a7d0070 from channel 'slow-topic' sent successfully to Kafka topic-partition 'slow-0', with offset 0] ==> expected: <true> but was: <false> within 30 seconds.
• Failed in jobs:
  • PR - Linux - JVM build - Latest Version

Failure stacktrace

org.awaitility.core.ConditionTimeoutException: Assertion condition defined as a Lambda expression in io.quarkus.test.utils.LogsVerifier Log does not contain any of '[ave]'. Full logs: [__  ____  __  _____   ___  __ ____  ______ ,  --/ __ \/ / / / _ | / _ \/ //_/ / / / __/ ,  -/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \   , --\___\_\____/_/ |_/_/|_/_/|_|\____/___/   , 12:53:48,486 SRMSG18229: Configured topics for channel 'slow': [slow], 12:53:48,500 SRMSG18214: Key deserializer omitted, using String as default, 12:53:48,500 SRMSG18234: Auto-commit disabled for channel slow, 12:53:48,671 SRMSG18240: 'throttled' commit strategy used for channel 'slow', 12:53:48,672 SRMSG18232: Will commit for group 'kafka-streams-reactive-messaging' every 5000 milliseconds., 12:53:48,672 SRMSG18236: Will mark throttled commit strategy for group 'kafka-streams-reactive-messaging' as unhealthy if records go more than 60000 milliseconds without being processed., 12:53:48,708 SRMSG18248: Key serializer omitted, using String as default, 12:53:48,739 SRMSG18258: Kafka producer kafka-producer-slow-topic, connected to Kafka brokers 'localhost:32781', is configured to write records to 'slow', 12:53:48,787 SRMSG18257: Kafka consumer kafka-consumer-slow, connected to Kafka brokers 'localhost:32781', belongs to the 'kafka-streams-reactive-messaging' consumer group and is configured to poll records from [slow], 12:53:48,791 No Topology producer; Kafka Streams will not be started, 12:53:48,877 kafka-streams-reactive-messaging 1.0.0-SNAPSHOT on JVM (powered by Quarkus 999-SNAPSHOT) started in 1.271s. Listening on: http://0.0.0.0:1104, 12:53:48,877 Profile prod activated. , 12:53:48,877 Installed features: [cdi, kafka-client, kafka-streams, messaging, messaging-kafka, resteasy, resteasy-jsonb, smallrye-context-propagation, vertx], 12:53:49,003 [Consumer clientId=kafka-consumer-slow, groupId=kafka-streams-reactive-messaging] Error while fetching metadata with correlation id 2 : {slow=UNKNOWN_TOPIC_OR_PARTITION}, 12:53:52,545 SRMSG18209: Sending message org.eclipse.microprofile.reactive.messaging.Message$5@1a7d0070 from channel 'slow-topic' to Kafka topic 'slow', 12:53:52,665 SRMSG18211: Message org.eclipse.microprofile.reactive.messaging.Message$5@1a7d0070 from channel 'slow-topic' sent successfully to Kafka topic-partition 'slow-0', with offset 0] ==> expected: <true> but was: <false> within 30 seconds.
	at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
	at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:119)
	at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:31)
	at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1006)
	at org.awaitility.core.ConditionFactory.untilAsserted(ConditionFactory.java:790)
	at io.quarkus.test.utils.AwaitilityUtils.untilAsserted(AwaitilityUtils.java:134)
	at io.quarkus.test.utils.AwaitilityUtils.untilAsserted(AwaitilityUtils.java:124)
	at io.quarkus.test.utils.LogsVerifier.assertContains(LogsVerifier.java:28)
	at io.quarkus.ts.messaging.kafka.reactive.streams.KafkaGratefulShutdownIT.testConnection(KafkaGratefulShutdownIT.java:72)
	at java.base/java.lang.reflect.Method.invoke(Method.java:569)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
Caused by: org.opentest4j.AssertionFailedError: Log does not contain any of '[ave]'. Full logs: [__  ____  __  _____   ___  __ ____  ______ ,  --/ __ \/ / / / _ | / _ \/ //_/ / / / __/ ,  -/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \   , --\___\_\____/_/ |_/_/|_/_/|_|\____/___/   , 12:53:48,486 SRMSG18229: Configured topics for channel 'slow': [slow], 12:53:48,500 SRMSG18214: Key deserializer omitted, using String as default, 12:53:48,500 SRMSG18234: Auto-commit disabled for channel slow, 12:53:48,671 SRMSG18240: 'throttled' commit strategy used for channel 'slow', 12:53:48,672 SRMSG18232: Will commit for group 'kafka-streams-reactive-messaging' every 5000 milliseconds., 12:53:48,672 SRMSG18236: Will mark throttled commit strategy for group 'kafka-streams-reactive-messaging' as unhealthy if records go more than 60000 milliseconds without being processed., 12:53:48,708 SRMSG18248: Key serializer omitted, using String as default, 12:53:48,739 SRMSG18258: Kafka producer kafka-producer-slow-topic, connected to Kafka brokers 'localhost:32781', is configured to write records to 'slow', 12:53:48,787 SRMSG18257: Kafka consumer kafka-consumer-slow, connected to Kafka brokers 'localhost:32781', belongs to the 'kafka-streams-reactive-messaging' consumer group and is configured to poll records from [slow], 12:53:48,791 No Topology producer; Kafka Streams will not be started, 12:53:48,877 kafka-streams-reactive-messaging 1.0.0-SNAPSHOT on JVM (powered by Quarkus 999-SNAPSHOT) started in 1.271s. Listening on: http://0.0.0.0:1104, 12:53:48,877 Profile prod activated. , 12:53:48,877 Installed features: [cdi, kafka-client, kafka-streams, messaging, messaging-kafka, resteasy, resteasy-jsonb, smallrye-context-propagation, vertx], 12:53:49,003 [Consumer clientId=kafka-consumer-slow, groupId=kafka-streams-reactive-messaging] Error while fetching metadata with correlation id 2 : {slow=UNKNOWN_TOPIC_OR_PARTITION}, 12:53:52,545 SRMSG18209: Sending message org.eclipse.microprofile.reactive.messaging.Message$5@1a7d0070 from channel 'slow-topic' to Kafka topic 'slow', 12:53:52,665 SRMSG18211: Message org.eclipse.microprofile.reactive.messaging.Message$5@1a7d0070 from channel 'slow-topic' sent successfully to Kafka topic-partition 'slow-0', with offset 0] ==> expected: <true> but was: <false>
	at io.quarkus.test.utils.LogsVerifier.lambda$assertContains$0(LogsVerifier.java:30)
	at org.awaitility.core.AssertionCondition.lambda$new$0(AssertionCondition.java:53)
	at org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:248)
	at org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:235)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:840)

---

[michalvavrik]

run tests