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

Reply via email to