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)
