AndrewJSchofield commented on PR #18718:
URL: https://github.com/apache/kafka/pull/18718#issuecomment-2621427484

   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 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

Reply via email to