apache/pulsar

Flaky-test: SimpleProducerConsumerTest.stateCheck

Open

#19,489 建立於 2023年2月11日

在 GitHub 查看
 (1 留言) (0 反應) (0 負責人)Java (13,697 star) (3,485 fork)batch import
Stalearea/testhelp wantedtype/flaky-tests

描述

Search before asking

  • I searched in the issues and found nothing similar.

Example failure

https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756428

Exception stacktrace

Error:  Tests run: 104, Failures: 1, Errors: 0, Skipped: 7, Time elapsed: 564.738 s <<< FAILURE! - in org.apache.pulsar.client.api.SimpleProducerConsumerTest
[1451](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1452)
  Error:  stateCheck(org.apache.pulsar.client.api.SimpleProducerConsumerTest)  Time elapsed: 161.755 s  <<< FAILURE!
[1452](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1453)
  org.apache.pulsar.client.admin.PulsarAdminException$ConflictException: Cluster already exists
[1453](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1454)
  	at org.apache.pulsar.client.admin.PulsarAdminException.wrap(PulsarAdminException.java:252)
[1454](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1455)
  	at org.apache.pulsar.client.admin.internal.BaseResource.sync(BaseResource.java:352)
[1455](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1456)
  	at org.apache.pulsar.client.admin.internal.ClustersImpl.createCluster(ClustersImpl.java:78)
[1456](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1457)
  	at org.apache.pulsar.client.api.ProducerConsumerBase.producerBaseSetup(ProducerConsumerBase.java:48)
[1457](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1458)
  	at org.apache.pulsar.client.api.SimpleProducerConsumerTest.setup(SimpleProducerConsumerTest.java:133)
[1458](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1459)
  	at org.apache.pulsar.tests.TestRetrySupport.stateCheck(TestRetrySupport.java:60)
[1459](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1460)
  	at jdk.internal.reflect.GeneratedMethodAccessor54.invoke(Unknown Source)
[1460](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1461)
  	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
[1461](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1462)
  	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
[1462](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1463)
  	at org.testng.internal.invokers.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:139)
[1463](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1464)
  	at org.testng.internal.invokers.MethodInvocationHelper.invokeMethodConsideringTimeout(MethodInvocationHelper.java:69)
[1464](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1465)
  	at org.testng.internal.invokers.ConfigInvoker.invokeConfigurationMethod(ConfigInvoker.java:361)
[1465](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1466)
  	at org.testng.internal.invokers.ConfigInvoker.invokeConfigurations(ConfigInvoker.java:296)
[1466](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1467)
  	at org.testng.internal.invokers.TestInvoker.runConfigMethods(TestInvoker.java:823)
[1467](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1468)
  	at org.testng.internal.invokers.TestInvoker.invokeMethod(TestInvoker.java:590)
[1468](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1469)
  	at org.testng.internal.invokers.TestInvoker.retryFailed(TestInvoker.java:263)
[1469](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1470)
  	at org.testng.internal.invokers.MethodRunner.runInSequence(MethodRunner.java:62)
[1470](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1471)
  	at org.testng.internal.invokers.TestInvoker$MethodInvocationAgent.invoke(TestInvoker.java:969)
[1471](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1472)
  	at org.testng.internal.invokers.TestInvoker.invokeTestMethods(TestInvoker.java:194)
[1472](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1473)
  	at org.testng.internal.invokers.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:148)
[1473](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1474)
  	at org.testng.internal.invokers.TestMethodWorker.run(TestMethodWorker.java:128)
[1474](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1475)
  	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
[1475](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1476)
  	at org.testng.TestRunner.privateRun(TestRunner.java:829)
[1476](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1477)
  	at org.testng.TestRunner.run(TestRunner.java:602)
[1477](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1478)
  	at org.testng.SuiteRunner.runTest(SuiteRunner.java:437)
[1478](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1479)
  	at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:431)
[1479](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1480)
  	at org.testng.SuiteRunner.privateRun(SuiteRunner.java:391)
[1480](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1481)
  	at org.testng.SuiteRunner.run(SuiteRunner.java:330)
[1481](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1482)
  	at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
[1482](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1483)
  	at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:95)
[1483](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1484)
  	at org.testng.TestNG.runSuitesSequentially(TestNG.java:1256)
[1484](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1485)
  	at org.testng.TestNG.runSuitesLocally(TestNG.java:1176)
[1485](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1486)
  	at org.testng.TestNG.runSuites(TestNG.java:1099)
[1486](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1487)
  	at org.testng.TestNG.run(TestNG.java:1067)
[1487](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1488)
  	at org.apache.maven.surefire.testng.TestNGExecutor.run(TestNGExecutor.java:135)
[1488](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1489)
  	at org.apache.maven.surefire.testng.TestNGDirectoryTestSuite.executeSingleClass(TestNGDirectoryTestSuite.java:112)
[1489](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1490)
  	at org.apache.maven.surefire.testng.TestNGDirectoryTestSuite.executeLazy(TestNGDirectoryTestSuite.java:123)
[1490](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1491)
  	at org.apache.maven.surefire.testng.TestNGDirectoryTestSuite.execute(TestNGDirectoryTestSuite.java:90)
[1491](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1492)
  	at org.apache.maven.surefire.testng.TestNGProvider.invoke(TestNGProvider.java:146)
[1492](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1493)
  	at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
[1493](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1494)
  	at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
[1494](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1495)
  	at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
[1495](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1496)
  	at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
[1496](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1497)
  	Suppressed: org.apache.pulsar.client.admin.PulsarAdminException$ConflictException: Cluster already exists
[1497](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1498)
  		at org.apache.pulsar.client.admin.internal.BaseResource.getApiException(BaseResource.java:287)
[1498](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1499)
  		at org.apache.pulsar.client.admin.internal.BaseResource$1.failed(BaseResource.java:136)
[1499](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1500)
  		at org.glassfish.jersey.client.JerseyInvocation$1.failed(JerseyInvocation.java:882)
[1500](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1501)
  		at org.glassfish.jersey.client.JerseyInvocation$1.completed(JerseyInvocation.java:863)
[1501](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1502)
  		at org.glassfish.jersey.client.ClientRuntime.processResponse(ClientRuntime.java:229)
[1502](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1503)
  		at org.glassfish.jersey.client.ClientRuntime.access$200(ClientRuntime.java:62)
[1503](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1504)
  		at org.glassfish.jersey.client.ClientRuntime$2.lambda$response$0(ClientRuntime.java:173)
[1504](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1505)
  		at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)
[1505](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1506)
  		at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
[1506](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1507)
  		at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
[1507](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1508)
  		at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
[1508](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1509)
  		at org.glassfish.jersey.internal.Errors.process(Errors.java:244)
[1509](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1510)
  		at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:288)
[1510](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1511)
  		at org.glassfish.jersey.client.ClientRuntime$2.response(ClientRuntime.java:173)
[1511](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1512)
  		at org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector.lambda$apply$1(AsyncHttpConnector.java:254)
[1512](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1513)
  		at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863)
[1513](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1514)
  		at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841)
[1514](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1515)
  		at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
[1515](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1516)
  		at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147)
[1516](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1517)
  		at org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector.lambda$retryOperation$4(AsyncHttpConnector.java:296)
[1517](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1518)
  		at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863)
[1518](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1519)
  		at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841)
[1519](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1520)
  		at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
[1520](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1521)
  		at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147)
[1521](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1522)
  		at org.asynchttpclient.netty.NettyResponseFuture.loadContent(NettyResponseFuture.java:222)
[1522](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1523)
  		at org.asynchttpclient.netty.NettyResponseFuture.done(NettyResponseFuture.java:257)
[1523](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1524)
  		at org.asynchttpclient.netty.handler.AsyncHttpClientHandler.finishUpdate(AsyncHttpClientHandler.java:241)
[1524](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1525)
  		at org.asynchttpclient.netty.handler.HttpHandler.handleChunk(HttpHandler.java:114)
[1525](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1526)
  		at org.asynchttpclient.netty.handler.HttpHandler.handleRead(HttpHandler.java:143)
[1526](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1527)
  		at org.asynchttpclient.netty.handler.AsyncHttpClientHandler.channelRead(AsyncHttpClientHandler.java:78)
[1527](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1528)
  		at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
[1528](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1529)
  		at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[1529](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1530)
  		at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[1530](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1531)
  		at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
[1531](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1532)
  		at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
[1532](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1533)
  		at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[1533](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1534)
  		at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[1534](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1535)
  		at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
[1535](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1536)
  		at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
[1536](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1537)
  		at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)
[1537](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1538)
  		at io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
[1538](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1539)
  		at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
[1539](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1540)
  		at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[1540](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1541)
  		at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[1541](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1542)
  		at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
[1542](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1543)
  		at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
[1543](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1544)
  		at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[1544](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1545)
  		at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
[1545](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1546)
  		at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
[1546](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1547)
  		at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788)
[1547](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1548)
  		at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
[1548](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1549)
  		at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
[1549](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1550)
  		at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
[1550](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1551)
  		at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
[1551](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1552)
  		at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
[1552](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1553)
  		at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[1553](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1554)
  		at java.base/java.lang.Thread.run(Thread.java:833)
[1554](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1555)
  	Caused by: javax.ws.rs.ClientErrorException: HTTP 409 {"reason":"Cluster already exists"}
[1555](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1556)
  		at org.glassfish.jersey.client.JerseyInvocation.createExceptionForFamily(JerseyInvocation.java:985)
[1556](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1557)
  		at org.glassfish.jersey.client.JerseyInvocation.convertToException(JerseyInvocation.java:967)
[1557](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1558)
  		at org.glassfish.jersey.client.JerseyInvocation.access$700(JerseyInvocation.java:82)
[1558](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1559)
  		... 54 more
[1559](https://github.com/apache/pulsar/actions/runs/4149057369/jobs/7177756249#step:11:1560)
  Caused by: [CIRCULAR REFERENCE: javax.ws.rs.ClientErrorException: HTTP 409 {"reason":"Cluster already exists"}]

Are you willing to submit a PR?

  • I'm willing to submit a PR!

貢獻者指南

技術棧
java
領域
testing
議題類型
bug
難度面向新貢獻者的預計實作難度，1 表示很小改動，5 表示專家級工作。
4
預計時間有經驗貢獻者完成調查、實作、測試並準備 pull request 的粗略時間範圍。
half day
活動狀態議題目前的可參與程度：新鮮、活躍、陳舊、阻塞或等待維護者輸入。
stale
清晰度議題是否清楚說明預期改動、驗收標準和下一步。
clear
前置要求
JavaMavenTestNGPulsar test infrastructure
新手友善度1-100 的估計分數，表示該議題對首次貢獻者的友善程度。
35
研究方向
Investigate the test setup in SimpleProducerConsumerTest.java and ProducerConsumerBase.java. The 'Cluster already exists' error suggests a missing cleanup between tests. Consider adding a cluster teardown method or ensuring unique cluster names per test run. Check if the stateCheck method in TestRetrySupport is properly handling retries.