[
https://issues.apache.org/jira/browse/KAFKA-18790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-18790.
------------------------------------
Resolution: Fixed
trunk:
https://github.com/apache/kafka/commit/e828767062feb163ea0506ac8c56dcf6f33268b4
4.0:
https://github.com/apache/kafka/commit/6abb4775b90465305bca2af344056cd828db7af8
> 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: Ming-Yen Chung
> Priority: Blocker
> Fix For: 4.0.0
>
>
> 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)
