smjn commented on PR #18718: URL: https://github.com/apache/kafka/pull/18718#issuecomment-2621556416
> Local test failure again: > > ``` > kafka.test.api.ShareConsumerTest.testComplexShareConsumer()[1] failed, log available in /Users/aschofield/kafkaoss/kafka/core/build/reports/testOutput/kafka.test.api.ShareConsumerTest.testComplexShareConsumer()[1].test.stdout > > Gradle Test Run :core:test > Gradle Test Executor 536 > ShareConsumerTest > testComplexShareConsumer() > testComplexShareConsumer [1] Type=Raft-Isolated, MetadataVersion=4.0-IV3,BrokerSecurityProtocol=PLAINTEXT,BrokerListenerName=ListenerName(EXTERNAL),ControllerSecurityProtocol=PLAINTEXT,ControllerListenerName=ListenerName(CONTROLLER) FAILED > java.lang.RuntimeException: Failed to start Raft server > at org.apache.kafka.common.test.junit.RaftClusterInvocationContext$RaftClusterInstance.start(RaftClusterInvocationContext.java:188) > at org.apache.kafka.common.test.junit.RaftClusterInvocationContext.lambda$getAdditionalExtensions$0(RaftClusterInvocationContext.java:96) > at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) > at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) > at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) > at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) > at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625) > at java.base/java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:762) > at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276) > at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625) > at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) > at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) > at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) > at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) > at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) > at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596) > at java.base/java.util.ArrayList.forEach(ArrayList.java:1511) > at java.base/java.util.ArrayList.forEach(ArrayList.java:1511) > > Caused by: > java.util.concurrent.ExecutionException: java.lang.RuntimeException: Received a fatal error while waiting for the controller to acknowledge that we are caught up > at java.base/java.util.concurrent.FutureTask.report(FutureTask.java:122) > at java.base/java.util.concurrent.FutureTask.get(FutureTask.java:191) > at org.apache.kafka.common.test.KafkaClusterTestKit.startup(KafkaClusterTestKit.java:469) > at org.apache.kafka.common.test.junit.RaftClusterInvocationContext$RaftClusterInstance.start(RaftClusterInvocationContext.java:181) > ... 17 more > > Caused by: > java.lang.RuntimeException: Received a fatal error while waiting for the controller to acknowledge that we are caught up > at org.apache.kafka.server.util.FutureUtils.waitWithLogging(FutureUtils.java:72) > at kafka.server.BrokerServer.startup(BrokerServer.scala:555) > at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) > 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) > > Caused by: > java.util.concurrent.CancellationException > at java.base/java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2478) > at kafka.server.BrokerLifecycleManager$ShutdownEvent.run(BrokerLifecycleManager.scala:629) > at org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:191) > ... 1 more > ``` > > I think it's going to take a bit of effort to work through this kind of thing. This not seem to be test related since the cluster instance creation faced issue. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
