You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Lianet Magrans (Jira)" <ji...@apache.org> on 2025/02/13 16:20:00 UTC
[jira] [Created] (KAFKA-18790) testCustomQuotaCallback time out build failure
Lianet Magrans created KAFKA-18790:
--------------------------------------
Summary: testCustomQuotaCallback time out build failure
Key: KAFKA-18790
URL: https://issues.apache.org/jira/browse/KAFKA-18790
Project: Kafka
Issue Type: Test
Reporter: Lianet Magrans
Recent transient build failure due to testCustomQuotaCallback timeout, recovered on the next run. The build was for a PR just fixing a flaky test unrelated to testCustomQuotaCallback (PR test passed successfully on that same failed build).
Investigating the transient build failure, it showed that the quarantine task had timed out. In the logs I could see that the testCustomQuotaCallback was once started but never finished
```
> Task :core:quarantinedTest
...
Gradle Test Run :core:quarantinedTest > Gradle Test Executor 112 > CustomQuotaCallbackTest > testCustomQuotaCallback(String, String) > testCustomQuotaCallback(String, String).quorum=kraft.groupProtocol=classic STARTED
...
> Task :core:quarantinedTest
...
Gradle Test Run :core:quarantinedTest > Gradle Test Executor 112 > CustomQuotaCallbackTest > testCustomQuotaCallback(String, String) > testCustomQuotaCallback(String, String).quorum=kraft.groupProtocol=classic PASSED
...
Gradle Test Run :core:quarantinedTest > Gradle Test Executor 112 > CustomQuotaCallbackTest > testCustomQuotaCallback(String, String) > testCustomQuotaCallback(String, String).quorum=kraft.groupProtocol=consumer STARTED
```
This last one never finished. And the thread dump showed:
```
"Test worker" #1 [7287] prio=5 os_prio=0 cpu=60168.75ms elapsed=10224.12s tid=0x00007f17d802fe70 nid=7287 waiting on condition [0x00007f17dd7f9000]
java.lang.Thread.State: WAITING (parking)
at jdk.internal.misc.Unsafe.park(java.base@23.0.2/Native Method)
- parking to wait for <0x0000000088705fa8> (a java.util.concurrent.CompletableFuture$Signaller)
at java.util.concurrent.locks.LockSupport.park(java.base@23.0.2/LockSupport.java:221)
at java.util.concurrent.CompletableFuture$Signaller.block(java.base@23.0.2/CompletableFuture.java:1908)
at java.util.concurrent.ForkJoinPool.unmanagedBlock(java.base@23.0.2/ForkJoinPool.java:4023)
at java.util.concurrent.ForkJoinPool.managedBlock(java.base@23.0.2/ForkJoinPool.java:3969)
at java.util.concurrent.CompletableFuture.waitingGet(java.base@23.0.2/CompletableFuture.java:1942)
at java.util.concurrent.CompletableFuture.get(java.base@23.0.2/CompletableFuture.java:2116)
at org.apache.kafka.clients.consumer.internals.ConsumerUtils.getResult(ConsumerUtils.java:238)
at org.apache.kafka.clients.consumer.internals.events.ApplicationEventHandler.addAndGet(ApplicationEventHandler.java:131)
at org.apache.kafka.clients.consumer.internals.AsyncKafkaConsumer.subscribeInternal(AsyncKafkaConsumer.java:1965)
at org.apache.kafka.clients.consumer.internals.AsyncKafkaConsumer.subscribe(AsyncKafkaConsumer.java:1817)
at org.apache.kafka.clients.consumer.KafkaConsumer.subscribe(KafkaConsumer.java:717)
at kafka.api.QuotaTestClients.consumeUntilThrottled(BaseQuotaTest.scala:238)
at kafka.api.CustomQuotaCallbackTest$GroupedUser.produceConsume(CustomQuotaCallbackTest.scala:322)
at kafka.api.CustomQuotaCallbackTest.testCustomQuotaCallback(CustomQuotaCallbackTest.scala:147)
```
Build with the test timeout:
[https://github.com/apache/kafka/actions/runs/13273058547/job/37110549871?pr=18866]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)