You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2025/02/13 16:48:00 UTC
[jira] [Assigned] (KAFKA-18790) testCustomQuotaCallback time out build failure
[ https://issues.apache.org/jira/browse/KAFKA-18790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chia-Ping Tsai reassigned KAFKA-18790:
--------------------------------------
Assignee: Chia-Ping Tsai
> 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
> Assignee: Chia-Ping Tsai
> Priority: Major
>
> 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
> {noformat}
> > 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
> ...{noformat}
>
> This last one never finished. And the thread dump showed:
> {code:java}
> "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)
> {code}
>
> 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)