lhotari opened a new issue #9407: URL: https://github.com/apache/pulsar/issues/9407
`org.apache.pulsar.admin.cli.PulsarAdminToolTest` is flaky. The `topics` test method fails sporadically. ``` Argument(s) are different! Wanted: topics.getMaxProducers( ``` [example failure 2021-02-01T10:05:15.6110573Z](https://github.com/apache/pulsar/runs/1804916977?check_suite_focus=true#step:6:18156) [example failure 2021-02-01T09:55:20.1615674Z](https://github.com/apache/pulsar/runs/1804916977?check_suite_focus=true#step:6:12063) [example failure 2021-02-01T09:51:38.6176407Z](https://github.com/apache/pulsar/runs/1804628430?check_suite_focus=true#step:6:18194) [example failure 2021-02-01T09:45:21.4073556Z](https://github.com/apache/pulsar/runs/1804916977?check_suite_focus=true#step:6:5971) [example failure 2021-02-01T09:40:12.7505875Z](https://github.com/apache/pulsar/runs/1804628430?check_suite_focus=true#step:6:12063) [example failure 2021-02-01T09:29:07.7501531Z](https://github.com/apache/pulsar/runs/1804628430?check_suite_focus=true#step:6:5971) [example failure 2021-02-01T08:48:11.2210807Z](https://github.com/apache/pulsar/runs/1804484406?check_suite_focus=true#step:6:15621) [example failure 2021-02-01T08:45:33.1879622Z](https://github.com/apache/pulsar/runs/1804483373?check_suite_focus=true#step:6:18156) [example failure 2021-02-01T08:37:23.3834714Z](https://github.com/apache/pulsar/runs/1804484406?check_suite_focus=true#step:6:9543) [example failure 2021-02-01T08:31:19.8838537Z](https://github.com/apache/pulsar/runs/1804483373?check_suite_focus=true#step:6:12063) [example failure 2021-02-01T08:17:09.0042408Z](https://github.com/apache/pulsar/runs/1804483373?check_suite_focus=true#step:6:5971) [example failure 2021-02-01T03:35:54.5536226Z](https://github.com/apache/pulsar/runs/1803613586?check_suite_focus=true#step:6:15668) [example failure 2021-02-01T03:08:24.3616889Z](https://github.com/apache/pulsar/runs/1803568446?check_suite_focus=true#step:6:12063) [example failure 2021-02-01T03:05:31.2400058Z](https://github.com/apache/pulsar/runs/1803613586?check_suite_focus=true#step:6:5971) [example failure 2021-02-01T02:53:28.4756535Z](https://github.com/apache/pulsar/runs/1803568446?check_suite_focus=true#step:6:5971) [example failure 2021-02-01T02:42:24.5589051Z](https://github.com/apache/pulsar/runs/1803442579?check_suite_focus=true#step:6:15668) [example failure 2021-02-01T02:32:23.3926531Z](https://github.com/apache/pulsar/runs/1803440602?check_suite_focus=true#step:6:14048) [example failure 2021-02-01T02:17:10.1012922Z](https://github.com/apache/pulsar/runs/1803440602?check_suite_focus=true#step:6:5975) [example failure 2021-02-01T02:16:12.7306969Z](https://github.com/apache/pulsar/runs/1803442579?check_suite_focus=true#step:6:5971) [example failure 2021-01-30T08:19:31.3335508Z](https://github.com/apache/pulsar/runs/1796622874?check_suite_focus=true#step:6:12416) [example failure 2021-01-30T08:05:15.3206231Z](https://github.com/apache/pulsar/runs/1796622874?check_suite_focus=true#step:6:6322) [example failure 2021-01-30T04:45:11.9653209Z](https://github.com/apache/pulsar/runs/1796067109?check_suite_focus=true#step:7:18156) [example failure 2021-01-30T04:36:25.6559242Z](https://github.com/apache/pulsar/runs/1796067109?check_suite_focus=true#step:7:12063) [example failure 2021-01-30T04:21:44.4060303Z](https://github.com/apache/pulsar/runs/1796067109?check_suite_focus=true#step:7:5971) [example failure 2021-01-29T00:40:23.3487134Z](https://github.com/apache/pulsar/runs/1788100839?check_suite_focus=true#step:7:18194) [example failure 2021-01-29T00:29:15.7909876Z](https://github.com/apache/pulsar/runs/1788100839?check_suite_focus=true#step:7:12101) [example failure 2021-01-29T00:12:36.7013899Z](https://github.com/apache/pulsar/runs/1788100839?check_suite_focus=true#step:7:5971) [example failure 2021-01-28T20:47:10.5113130Z](https://github.com/apache/pulsar/runs/1786880021?check_suite_focus=true#step:6:15668) [example failure 2021-01-28T20:20:04.4089181Z](https://github.com/apache/pulsar/runs/1786880021?check_suite_focus=true#step:6:5971) [example failure 2021-01-28T14:09:57.4771528Z](https://github.com/apache/pulsar/runs/1784077549?check_suite_focus=true#step:6:18156) [example failure 2021-01-28T14:01:17.2904137Z](https://github.com/apache/pulsar/runs/1784077549?check_suite_focus=true#step:6:12063) [example failure 2021-01-28T14:00:18.9413062Z](https://github.com/apache/pulsar/runs/1783830906?check_suite_focus=true#step:7:15668) [example failure 2021-01-28T13:52:44.7246000Z](https://github.com/apache/pulsar/runs/1784077549?check_suite_focus=true#step:6:5971) [example failure 2021-01-28T13:50:20.0296370Z](https://github.com/apache/pulsar/runs/1783830906?check_suite_focus=true#step:7:9576) [example failure 2021-01-28T13:42:25.5258673Z](https://github.com/apache/pulsar/runs/1783349213?check_suite_focus=true#step:6:15668) [example failure 2021-01-28T13:26:37.6673519Z](https://github.com/apache/pulsar/runs/1783349213?check_suite_focus=true#step:6:9576) [example failure 2021-01-28T04:04:42.7078568Z](https://github.com/apache/pulsar/runs/1781267667?check_suite_focus=true#step:6:16234) [example failure 2021-01-28T03:41:13.6276099Z](https://github.com/apache/pulsar/runs/1781267667?check_suite_focus=true#step:6:6240) [example failure 2021-01-28T02:41:16.4320787Z](https://github.com/apache/pulsar/runs/1781184081?check_suite_focus=true#step:6:18158) [example failure 2021-01-28T02:26:00.6464736Z](https://github.com/apache/pulsar/runs/1781184081?check_suite_focus=true#step:6:12065) [example failure 2021-01-28T02:11:27.5800365Z](https://github.com/apache/pulsar/runs/1781184081?check_suite_focus=true#step:6:5973) [example failure 2021-01-28T00:29:50.1485316Z](https://github.com/apache/pulsar/runs/1780053828?check_suite_focus=true#step:6:18151) [example failure 2021-01-28T00:19:48.6054972Z](https://github.com/apache/pulsar/runs/1780053828?check_suite_focus=true#step:6:12072) [example failure 2021-01-28T00:09:03.6789274Z](https://github.com/apache/pulsar/runs/1780053828?check_suite_focus=true#step:6:5956) [example failure 2021-01-27T23:16:12.9056043Z](https://github.com/apache/pulsar/runs/1779704123?check_suite_focus=true#step:6:18158) [example failure 2021-01-27T23:00:26.6888044Z](https://github.com/apache/pulsar/runs/1779704123?check_suite_focus=true#step:6:12065) [example failure 2021-01-27T22:50:09.8225097Z](https://github.com/apache/pulsar/runs/1779704123?check_suite_focus=true#step:6:5973) [example failure 2021-01-27T22:18:52.2012608Z](https://github.com/apache/pulsar/runs/1778470820?check_suite_focus=true#step:6:18151) [example failure 2021-01-27T22:03:30.0538073Z](https://github.com/apache/pulsar/runs/1778470820?check_suite_focus=true#step:6:12072) [example failure 2021-01-27T21:43:13.0395214Z](https://github.com/apache/pulsar/runs/1778470820?check_suite_focus=true#step:6:5956) [example failure 2021-01-27T16:33:27.3780807Z](https://github.com/apache/pulsar/runs/1777187576?check_suite_focus=true#step:6:18196) [example failure 2021-01-27T16:14:35.5785700Z](https://github.com/apache/pulsar/runs/1777187576?check_suite_focus=true#step:6:12103) [example failure 2021-01-27T16:05:07.1633467Z](https://github.com/apache/pulsar/runs/1777187576?check_suite_focus=true#step:6:5973) [example failure 2021-01-27T12:25:26.5148380Z](https://github.com/apache/pulsar/runs/1775096701?check_suite_focus=true#step:6:18145) [example failure 2021-01-27T12:10:07.3500186Z](https://github.com/apache/pulsar/runs/1775096701?check_suite_focus=true#step:6:12068) [example failure 2021-01-27T11:49:32.8058739Z](https://github.com/apache/pulsar/runs/1775096701?check_suite_focus=true#step:6:5954) [example failure 2021-01-27T07:14:28.2366588Z](https://github.com/apache/pulsar/runs/1774769134?check_suite_focus=true#step:6:12073) [example failure 2021-01-27T06:58:53.6437165Z](https://github.com/apache/pulsar/runs/1774769134?check_suite_focus=true#step:6:5977) [example failure 2021-01-27T06:04:57.3369228Z](https://github.com/apache/pulsar/runs/1774530569?check_suite_focus=true#step:6:18113) [example failure 2021-01-27T05:51:10.2522377Z](https://github.com/apache/pulsar/runs/1774530569?check_suite_focus=true#step:6:12034) [example failure 2021-01-27T05:37:09.5762019Z](https://github.com/apache/pulsar/runs/1774530569?check_suite_focus=true#step:6:5956) [example failure 2021-01-27T01:41:35.0466571Z](https://github.com/apache/pulsar/runs/1773580180?check_suite_focus=true#step:6:18107) [example failure 2021-01-27T01:32:16.6448989Z](https://github.com/apache/pulsar/runs/1773580180?check_suite_focus=true#step:6:12030) [example failure 2021-01-27T01:22:07.5090106Z](https://github.com/apache/pulsar/runs/1773580180?check_suite_focus=true#step:6:5954) [example failure 2021-01-26T21:15:48.8526197Z](https://github.com/apache/pulsar/runs/1770196604?check_suite_focus=true#step:6:18113) [example failure 2021-01-26T21:02:05.3576961Z](https://github.com/apache/pulsar/runs/1770196604?check_suite_focus=true#step:6:12034) [example failure 2021-01-26T20:47:51.2587557Z](https://github.com/apache/pulsar/runs/1770196604?check_suite_focus=true#step:6:5956) [example failure 2021-01-26T13:52:03.6516789Z](https://github.com/apache/pulsar/runs/1767980030?check_suite_focus=true#step:6:18145) [example failure 2021-01-26T13:36:14.8299710Z](https://github.com/apache/pulsar/runs/1767980030?check_suite_focus=true#step:6:12030) [example failure 2021-01-26T13:21:04.1934359Z](https://github.com/apache/pulsar/runs/1767980030?check_suite_focus=true#step:6:5954) <details> <summary>Full exception stacktrace</summary> <code><pre> Argument(s) are different! Wanted: topics.getMaxProducers( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.PulsarAdminToolTest.topics(PulsarAdminToolTest.java:851) Actual invocations have different arguments: topics.delete( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DeleteCmd.run(CmdTopics.java:469) topics.unload( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$UnloadCmd.run(CmdTopics.java:484) topics.getList( "myprop/clust/ns1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$ListCmd.run(CmdTopics.java:246) topics.getSubscriptions( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$ListSubscriptions.run(CmdTopics.java:496) topics.deleteSubscription( "persistent://myprop/clust/ns1/ds1", "sub1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DeleteSubscription.run(CmdTopics.java:516) topics.getStats( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetStats.run(CmdTopics.java:533) topics.getInternalStats( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetInternalStats.run(CmdTopics.java:549) topics.getInternalInfo( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetInternalInfo.run(CmdTopics.java:561) topics.getPartitionedStats( "persistent://myprop/clust/ns1/ds1", true, false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetPartitionedStats.run(CmdTopics.java:583) topics.getPartitionedInternalStats( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetPartitionedStatsInternal.run(CmdTopics.java:596) topics.skipAllMessages( "persistent://myprop/clust/ns1/ds1", "sub1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$ClearBacklog.run(CmdTopics.java:611) topics.skipMessages( "persistent://myprop/clust/ns1/ds1", "sub1", 100L ); -> at org.apache.pulsar.admin.cli.CmdTopics$Skip.run(CmdTopics.java:630) topics.expireMessages( "persistent://myprop/clust/ns1/ds1", "sub1", 100L ); -> at org.apache.pulsar.admin.cli.CmdTopics$ExpireMessages.run(CmdTopics.java:649) topics.expireMessagesForAllSubscriptions( "persistent://myprop/clust/ns1/ds1", 100L ); -> at org.apache.pulsar.admin.cli.CmdTopics$ExpireMessagesForAllSubscriptions.run(CmdTopics.java:664) topics.createSubscription( "persistent://myprop/clust/ns1/ds1", "sub1", -1:-1:-1 ); -> at org.apache.pulsar.admin.cli.CmdTopics$CreateSubscription.run(CmdTopics.java:693) topics.createPartitionedTopic( "persistent://myprop/clust/ns1/ds1", 32 ); -> at org.apache.pulsar.admin.cli.CmdTopics$CreatePartitionedCmd.run(CmdTopics.java:363) topics.createNonPartitionedTopic( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$CreateNonPartitionedCmd.run(CmdTopics.java:391) topics.getPartitionedTopicList( "myprop/clust/ns1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$PartitionedTopicListCmd.run(CmdTopics.java:258) topics.getPartitionedTopicMetadata( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetPartitionedTopicMetadataCmd.run(CmdTopics.java:423) topics.deletePartitionedTopic( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DeletePartitionedCmd.run(CmdTopics.java:445) topics.peekMessages( "persistent://myprop/clust/ns1/ds1", "sub1", 3 ); -> at org.apache.pulsar.admin.cli.CmdTopics$PeekMessages.run(CmdTopics.java:774) topics.enableDeduplication( "persistent://myprop/clust/ns1/ds1", true ); -> at org.apache.pulsar.admin.cli.CmdTopics$EnableDeduplication.run(CmdTopics.java:1275) topics.enableDeduplication( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DisableDeduplication.run(CmdTopics.java:1288) topics.enableDeduplication( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetDeduplication.run(CmdTopics.java:1310) topics.getReplicatorDispatchRate( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetReplicatorDispatchRate.run(CmdTopics.java:1770) topics.setReplicatorDispatchRate( "persistent://myprop/clust/ns1/ds1", DispatchRate{dispatchThrottlingRateInMsg=10, dispatchThrottlingRateInByte=11, ratePeriodInSecond=12} ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetReplicatorDispatchRate.run(CmdTopics.java:1798) topics.removeReplicatorDispatchRate( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveReplicatorDispatchRate.run(CmdTopics.java:1811) topics.getDeduplicationEnabled( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetDeduplicationEnabled.run(CmdTopics.java:1322) topics.getDeduplicationEnabled( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetDeduplicationEnabled.run(CmdTopics.java:1322) topics.getOffloadPolicies( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetOffloadPolicies.run(CmdTopics.java:1358) topics.removeOffloadPolicies( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveOffloadPolicies.run(CmdTopics.java:1370) topics.getDelayedDeliveryPolicy( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetDelayedDelivery.run(CmdTopics.java:1081) topics.setDelayedDeliveryPolicy( "persistent://myprop/clust/ns1/ds1", DelayedDeliveryPolicies(tickTime=10000, active=true) ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetDelayedDelivery.run(CmdTopics.java:1109) topics.removeDelayedDeliveryPolicy( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveDelayedDelivery.run(CmdTopics.java:1121) topics.setOffloadPolicies( "persistent://myprop/clust/ns1/ds1", OffloadPolicies{managedLedgerOffloadedReadPriority=tiered-storage-first, managedLedgerOffloadDriver=s3, managedLedgerOffloadMaxThreads=2, managedLedgerOffloadPrefetchRounds=1, managedLedgerOffloadAutoTriggerSizeThresholdBytes=10, managedLedgerOffloadDeletionLagInMillis=null, s3ManagedLedgerOffloadRegion=region, s3ManagedLedgerOffloadBucket=bucket, s3ManagedLedgerOffloadServiceEndpoint=endpoint, s3ManagedLedgerOffloadMaxBlockSizeInBytes=8, s3ManagedLedgerOffloadReadBufferSizeInBytes=9, s3ManagedLedgerOffloadRole=null, s3ManagedLedgerOffloadRoleSessionName=pulsar-s3-offload, gcsManagedLedgerOffloadRegion=null, gcsManagedLedgerOffloadBucket=null, gcsManagedLedgerOffloadMaxBlockSizeInBytes=67108864, gcsManagedLedgerOffloadReadBufferSizeInBytes=1048576, gcsManagedLedgerOffloadServiceAccountKeyFile=null, fileSystemProfilePath=null, fileSystemURI=null, managedLedgerOffloadBucket=bucket, managedLedgerOffloadRegion=region, managedLedgerOffloadServiceEndpoint=endpoint, managedLedgerOffl oadMaxBlockSizeInBytes=8, managedLedgerOffloadReadBufferSizeInBytes=9} ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetOffloadPolicies.run(CmdTopics.java:1446) topics.getMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1552) topics.getMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1552) topics.removeMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1564) topics.removeMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1564) topics.setMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1", 999 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1579) topics.setMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1", 999 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1579) topics.getMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1591) topics.getMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1591) topics.removeMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1603) topics.removeMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1603) topics.setMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1618) topics.setMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1618) topics.getMaxMessageSize( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxMessageSize.run(CmdTopics.java:1905) topics.removeMaxMessageSize( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxMessageSize.run(CmdTopics.java:1932) topics.setMaxMessageSize( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxMessageSize.run(CmdTopics.java:1920) topics.getMaxProducers( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxProducers.run(CmdTopics.java:1826) at org.apache.pulsar.admin.cli.PulsarAdminToolTest.topics(PulsarAdminToolTest.java:851) at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:132) at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:45) at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:73) at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:11) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) </pre></code> </details> [example failure 2021-01-28T02:13:03.7497130Z](https://github.com/apache/pulsar/runs/1781059703?check_suite_focus=true#step:6:18176) [example failure 2021-01-28T02:04:11.9932048Z](https://github.com/apache/pulsar/runs/1781059703?check_suite_focus=true#step:6:12077) [example failure 2021-01-28T01:50:25.7516768Z](https://github.com/apache/pulsar/runs/1781059703?check_suite_focus=true#step:6:5979) [example failure 2021-01-27T17:14:16.9470392Z](https://github.com/apache/pulsar/runs/1777204471?check_suite_focus=true#step:6:12766) [example failure 2021-01-27T17:00:03.4391240Z](https://github.com/apache/pulsar/runs/1777204471?check_suite_focus=true#step:6:6668) <details> <summary>Full exception stacktrace</summary> <code><pre> Argument(s) are different! Wanted: topics.getMaxProducers( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.PulsarAdminToolTest.topics(PulsarAdminToolTest.java:876) Actual invocations have different arguments: topics.delete( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DeleteCmd.run(CmdTopics.java:469) topics.unload( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$UnloadCmd.run(CmdTopics.java:484) topics.getList( "myprop/clust/ns1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$ListCmd.run(CmdTopics.java:246) topics.getSubscriptions( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$ListSubscriptions.run(CmdTopics.java:496) topics.deleteSubscription( "persistent://myprop/clust/ns1/ds1", "sub1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DeleteSubscription.run(CmdTopics.java:516) topics.getStats( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetStats.run(CmdTopics.java:533) topics.getInternalStats( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetInternalStats.run(CmdTopics.java:549) topics.getInternalInfo( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetInternalInfo.run(CmdTopics.java:561) topics.getPartitionedStats( "persistent://myprop/clust/ns1/ds1", true, false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetPartitionedStats.run(CmdTopics.java:583) topics.getPartitionedInternalStats( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetPartitionedStatsInternal.run(CmdTopics.java:596) topics.skipAllMessages( "persistent://myprop/clust/ns1/ds1", "sub1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$ClearBacklog.run(CmdTopics.java:611) topics.skipMessages( "persistent://myprop/clust/ns1/ds1", "sub1", 100L ); -> at org.apache.pulsar.admin.cli.CmdTopics$Skip.run(CmdTopics.java:630) topics.expireMessages( "persistent://myprop/clust/ns1/ds1", "sub1", 100L ); -> at org.apache.pulsar.admin.cli.CmdTopics$ExpireMessages.run(CmdTopics.java:649) topics.expireMessagesForAllSubscriptions( "persistent://myprop/clust/ns1/ds1", 100L ); -> at org.apache.pulsar.admin.cli.CmdTopics$ExpireMessagesForAllSubscriptions.run(CmdTopics.java:664) topics.createSubscription( "persistent://myprop/clust/ns1/ds1", "sub1", -1:-1:-1 ); -> at org.apache.pulsar.admin.cli.CmdTopics$CreateSubscription.run(CmdTopics.java:693) topics.createPartitionedTopic( "persistent://myprop/clust/ns1/ds1", 32 ); -> at org.apache.pulsar.admin.cli.CmdTopics$CreatePartitionedCmd.run(CmdTopics.java:363) topics.createNonPartitionedTopic( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$CreateNonPartitionedCmd.run(CmdTopics.java:391) topics.getPartitionedTopicList( "myprop/clust/ns1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$PartitionedTopicListCmd.run(CmdTopics.java:258) topics.getPartitionedTopicMetadata( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetPartitionedTopicMetadataCmd.run(CmdTopics.java:423) topics.deletePartitionedTopic( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DeletePartitionedCmd.run(CmdTopics.java:445) topics.peekMessages( "persistent://myprop/clust/ns1/ds1", "sub1", 3 ); -> at org.apache.pulsar.admin.cli.CmdTopics$PeekMessages.run(CmdTopics.java:774) topics.enableDeduplication( "persistent://myprop/clust/ns1/ds1", true ); -> at org.apache.pulsar.admin.cli.CmdTopics$EnableDeduplication.run(CmdTopics.java:1275) topics.enableDeduplication( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DisableDeduplication.run(CmdTopics.java:1288) topics.enableDeduplication( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetDeduplication.run(CmdTopics.java:1310) topics.getReplicatorDispatchRate( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetReplicatorDispatchRate.run(CmdTopics.java:1795) topics.setReplicatorDispatchRate( "persistent://myprop/clust/ns1/ds1", DispatchRate{dispatchThrottlingRateInMsg=10, dispatchThrottlingRateInByte=11, ratePeriodInSecond=12} ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetReplicatorDispatchRate.run(CmdTopics.java:1823) topics.removeReplicatorDispatchRate( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveReplicatorDispatchRate.run(CmdTopics.java:1836) topics.getDeduplicationEnabled( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetDeduplicationEnabled.run(CmdTopics.java:1322) topics.getDeduplicationEnabled( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetDeduplicationEnabled.run(CmdTopics.java:1322) topics.getOffloadPolicies( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetOffloadPolicies.run(CmdTopics.java:1358) topics.removeOffloadPolicies( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveOffloadPolicies.run(CmdTopics.java:1370) topics.getDelayedDeliveryPolicy( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetDelayedDelivery.run(CmdTopics.java:1081) topics.setDelayedDeliveryPolicy( "persistent://myprop/clust/ns1/ds1", DelayedDeliveryPolicies(tickTime=10000, active=true) ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetDelayedDelivery.run(CmdTopics.java:1109) topics.removeDelayedDeliveryPolicy( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveDelayedDelivery.run(CmdTopics.java:1121) topics.setOffloadPolicies( "persistent://myprop/clust/ns1/ds1", OffloadPolicies{offloadMethod=streaming-based, managedLedgerOffloadedReadPriority=tiered-storage-first, managedLedgerOffloadDriver=s3, managedLedgerOffloadMaxThreads=2, managedLedgerOffloadPrefetchRounds=1, managedLedgerOffloadAutoTriggerSizeThresholdBytes=10, managedLedgerOffloadDeletionLagInMillis=null, s3ManagedLedgerOffloadRegion=region, s3ManagedLedgerOffloadBucket=bucket, s3ManagedLedgerOffloadServiceEndpoint=endpoint, s3ManagedLedgerOffloadMaxBlockSizeInBytes=8, s3ManagedLedgerOffloadReadBufferSizeInBytes=9, s3ManagedLedgerOffloadRole=null, s3ManagedLedgerOffloadRoleSessionName=pulsar-s3-offload, gcsManagedLedgerOffloadRegion=null, gcsManagedLedgerOffloadBucket=null, gcsManagedLedgerOffloadMaxBlockSizeInBytes=67108864, gcsManagedLedgerOffloadReadBufferSizeInBytes=1048576, gcsManagedLedgerOffloadServiceAccountKeyFile=null, fileSystemProfilePath=null, fileSystemURI=null, managedLedgerOffloadBucket=bucket, managedLedgerOffloadRegion=region, managedLedgerOffloadServiceEndpo int=endpoint, managedLedgerOffloadMaxBlockSizeInBytes=8, managedLedgerOffloadReadBufferSizeInBytes=9} ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetOffloadPolicies.run(CmdTopics.java:1471) topics.getMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1577) topics.getMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1577) topics.removeMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1589) topics.removeMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1589) topics.setMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1", 999 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1604) topics.setMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1", 999 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1604) topics.getMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1616) topics.getMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1616) topics.removeMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1628) topics.removeMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1628) topics.setMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1643) topics.setMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1643) topics.getMaxMessageSize( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxMessageSize.run(CmdTopics.java:1930) topics.removeMaxMessageSize( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxMessageSize.run(CmdTopics.java:1957) topics.setMaxMessageSize( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxMessageSize.run(CmdTopics.java:1945) topics.getMaxProducers( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxProducers.run(CmdTopics.java:1851) at org.apache.pulsar.admin.cli.PulsarAdminToolTest.topics(PulsarAdminToolTest.java:876) at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:132) at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:45) at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:73) at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:11) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) </pre></code> </details> [example failure 2021-01-27T13:33:14.5500218Z](https://github.com/apache/pulsar/runs/1775226745?check_suite_focus=true#step:6:18158) [example failure 2021-01-27T13:17:31.9162496Z](https://github.com/apache/pulsar/runs/1775226745?check_suite_focus=true#step:6:12065) [example failure 2021-01-27T13:01:44.4871434Z](https://github.com/apache/pulsar/runs/1775226745?check_suite_focus=true#step:6:5973) <details> <summary>Full exception stacktrace</summary> <code><pre> Argument(s) are different! Wanted: topics.getMaxProducers( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.PulsarAdminToolTest.topics(PulsarAdminToolTest.java:831) Actual invocations have different arguments: topics.delete( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DeleteCmd.run(CmdTopics.java:469) topics.unload( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$UnloadCmd.run(CmdTopics.java:484) topics.getList( "myprop/clust/ns1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$ListCmd.run(CmdTopics.java:246) topics.getSubscriptions( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$ListSubscriptions.run(CmdTopics.java:496) topics.deleteSubscription( "persistent://myprop/clust/ns1/ds1", "sub1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DeleteSubscription.run(CmdTopics.java:516) topics.getStats( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetStats.run(CmdTopics.java:533) topics.getInternalStats( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetInternalStats.run(CmdTopics.java:549) topics.getInternalInfo( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetInternalInfo.run(CmdTopics.java:561) topics.getPartitionedStats( "persistent://myprop/clust/ns1/ds1", true, false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetPartitionedStats.run(CmdTopics.java:583) topics.getPartitionedInternalStats( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetPartitionedStatsInternal.run(CmdTopics.java:596) topics.skipAllMessages( "persistent://myprop/clust/ns1/ds1", "sub1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$ClearBacklog.run(CmdTopics.java:611) topics.skipMessages( "persistent://myprop/clust/ns1/ds1", "sub1", 100L ); -> at org.apache.pulsar.admin.cli.CmdTopics$Skip.run(CmdTopics.java:630) topics.expireMessages( "persistent://myprop/clust/ns1/ds1", "sub1", 100L ); -> at org.apache.pulsar.admin.cli.CmdTopics$ExpireMessages.run(CmdTopics.java:649) topics.expireMessagesForAllSubscriptions( "persistent://myprop/clust/ns1/ds1", 100L ); -> at org.apache.pulsar.admin.cli.CmdTopics$ExpireMessagesForAllSubscriptions.run(CmdTopics.java:664) topics.createSubscription( "persistent://myprop/clust/ns1/ds1", "sub1", -1:-1:-1 ); -> at org.apache.pulsar.admin.cli.CmdTopics$CreateSubscription.run(CmdTopics.java:693) topics.createPartitionedTopic( "persistent://myprop/clust/ns1/ds1", 32 ); -> at org.apache.pulsar.admin.cli.CmdTopics$CreatePartitionedCmd.run(CmdTopics.java:363) topics.createNonPartitionedTopic( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$CreateNonPartitionedCmd.run(CmdTopics.java:391) topics.getPartitionedTopicList( "myprop/clust/ns1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$PartitionedTopicListCmd.run(CmdTopics.java:258) topics.getPartitionedTopicMetadata( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetPartitionedTopicMetadataCmd.run(CmdTopics.java:423) topics.deletePartitionedTopic( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DeletePartitionedCmd.run(CmdTopics.java:445) topics.peekMessages( "persistent://myprop/clust/ns1/ds1", "sub1", 3 ); -> at org.apache.pulsar.admin.cli.CmdTopics$PeekMessages.run(CmdTopics.java:774) topics.enableDeduplication( "persistent://myprop/clust/ns1/ds1", true ); -> at org.apache.pulsar.admin.cli.CmdTopics$EnableDeduplication.run(CmdTopics.java:1275) topics.enableDeduplication( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DisableDeduplication.run(CmdTopics.java:1288) topics.enableDeduplication( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetDeduplication.run(CmdTopics.java:1310) topics.getReplicatorDispatchRate( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetReplicatorDispatchRate.run(CmdTopics.java:1770) topics.setReplicatorDispatchRate( "persistent://myprop/clust/ns1/ds1", DispatchRate{dispatchThrottlingRateInMsg=10, dispatchThrottlingRateInByte=11, ratePeriodInSecond=12} ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetReplicatorDispatchRate.run(CmdTopics.java:1798) topics.removeReplicatorDispatchRate( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveReplicatorDispatchRate.run(CmdTopics.java:1811) topics.getDeduplicationEnabled( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetDeduplicationEnabled.run(CmdTopics.java:1322) topics.getDeduplicationEnabled( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetDeduplicationEnabled.run(CmdTopics.java:1322) topics.getOffloadPolicies( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetOffloadPolicies.run(CmdTopics.java:1358) topics.removeOffloadPolicies( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveOffloadPolicies.run(CmdTopics.java:1370) topics.getDelayedDeliveryPolicy( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetDelayedDelivery.run(CmdTopics.java:1081) topics.setDelayedDeliveryPolicy( "persistent://myprop/clust/ns1/ds1", DelayedDeliveryPolicies(tickTime=10000, active=true) ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetDelayedDelivery.run(CmdTopics.java:1109) topics.removeDelayedDeliveryPolicy( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveDelayedDelivery.run(CmdTopics.java:1121) topics.setOffloadPolicies( "persistent://myprop/clust/ns1/ds1", OffloadPolicies{managedLedgerOffloadedReadPriority=tiered-storage-first, managedLedgerOffloadDriver=s3, managedLedgerOffloadMaxThreads=2, managedLedgerOffloadPrefetchRounds=1, managedLedgerOffloadAutoTriggerSizeThresholdBytes=10, managedLedgerOffloadDeletionLagInMillis=null, s3ManagedLedgerOffloadRegion=region, s3ManagedLedgerOffloadBucket=bucket, s3ManagedLedgerOffloadServiceEndpoint=endpoint, s3ManagedLedgerOffloadMaxBlockSizeInBytes=8, s3ManagedLedgerOffloadReadBufferSizeInBytes=9, s3ManagedLedgerOffloadRole=null, s3ManagedLedgerOffloadRoleSessionName=pulsar-s3-offload, gcsManagedLedgerOffloadRegion=null, gcsManagedLedgerOffloadBucket=null, gcsManagedLedgerOffloadMaxBlockSizeInBytes=67108864, gcsManagedLedgerOffloadReadBufferSizeInBytes=1048576, gcsManagedLedgerOffloadServiceAccountKeyFile=null, fileSystemProfilePath=null, fileSystemURI=null, managedLedgerOffloadBucket=bucket, managedLedgerOffloadRegion=region, managedLedgerOffloadServiceEndpoint=endpoint, managedLedgerOffl oadMaxBlockSizeInBytes=8, managedLedgerOffloadReadBufferSizeInBytes=9} ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetOffloadPolicies.run(CmdTopics.java:1446) topics.getMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1552) topics.getMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1552) topics.removeMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1564) topics.removeMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1564) topics.setMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1", 999 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1579) topics.setMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1", 999 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1579) topics.getMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1591) topics.getMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1591) topics.removeMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1603) topics.removeMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1603) topics.setMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1618) topics.setMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1618) topics.getMaxMessageSize( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxMessageSize.run(CmdTopics.java:1905) topics.removeMaxMessageSize( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxMessageSize.run(CmdTopics.java:1932) topics.setMaxMessageSize( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxMessageSize.run(CmdTopics.java:1920) topics.getMaxProducers( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxProducers.run(CmdTopics.java:1826) at org.apache.pulsar.admin.cli.PulsarAdminToolTest.topics(PulsarAdminToolTest.java:831) at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:132) at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:45) at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:73) at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:11) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) </pre></code> </details> ``` Argument(s) are different! Wanted: topics.getMaxConsumers( ``` [example failure 2021-01-29T07:51:03.1739828Z](https://github.com/apache/pulsar/runs/1789838309?check_suite_focus=true#step:6:18218) [example failure 2021-01-29T07:41:49.3990190Z](https://github.com/apache/pulsar/runs/1789838309?check_suite_focus=true#step:6:12095) [example failure 2021-01-29T07:32:56.2643242Z](https://github.com/apache/pulsar/runs/1789838309?check_suite_focus=true#step:6:5973) <details> <summary>Full exception stacktrace</summary> <code><pre> Argument(s) are different! Wanted: topics.getMaxConsumers( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.PulsarAdminToolTest.topics(PulsarAdminToolTest.java:858) Actual invocations have different arguments: topics.delete( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DeleteCmd.run(CmdTopics.java:476) topics.unload( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$UnloadCmd.run(CmdTopics.java:491) topics.getList( "myprop/clust/ns1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$ListCmd.run(CmdTopics.java:253) topics.getSubscriptions( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$ListSubscriptions.run(CmdTopics.java:503) topics.deleteSubscription( "persistent://myprop/clust/ns1/ds1", "sub1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DeleteSubscription.run(CmdTopics.java:523) topics.getStats( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetStats.run(CmdTopics.java:540) topics.getInternalStats( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetInternalStats.run(CmdTopics.java:556) topics.getInternalInfo( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetInternalInfo.run(CmdTopics.java:568) topics.getPartitionedStats( "persistent://myprop/clust/ns1/ds1", true, false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetPartitionedStats.run(CmdTopics.java:590) topics.getPartitionedInternalStats( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetPartitionedStatsInternal.run(CmdTopics.java:603) topics.skipAllMessages( "persistent://myprop/clust/ns1/ds1", "sub1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$ClearBacklog.run(CmdTopics.java:618) topics.skipMessages( "persistent://myprop/clust/ns1/ds1", "sub1", 100L ); -> at org.apache.pulsar.admin.cli.CmdTopics$Skip.run(CmdTopics.java:637) topics.expireMessages( "persistent://myprop/clust/ns1/ds1", "sub1", 100L ); -> at org.apache.pulsar.admin.cli.CmdTopics$ExpireMessages.run(CmdTopics.java:656) topics.expireMessagesForAllSubscriptions( "persistent://myprop/clust/ns1/ds1", 100L ); -> at org.apache.pulsar.admin.cli.CmdTopics$ExpireMessagesForAllSubscriptions.run(CmdTopics.java:671) topics.createSubscription( "persistent://myprop/clust/ns1/ds1", "sub1", -1:-1:-1 ); -> at org.apache.pulsar.admin.cli.CmdTopics$CreateSubscription.run(CmdTopics.java:700) topics.createPartitionedTopic( "persistent://myprop/clust/ns1/ds1", 32 ); -> at org.apache.pulsar.admin.cli.CmdTopics$CreatePartitionedCmd.run(CmdTopics.java:370) topics.createNonPartitionedTopic( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$CreateNonPartitionedCmd.run(CmdTopics.java:398) topics.getPartitionedTopicList( "myprop/clust/ns1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$PartitionedTopicListCmd.run(CmdTopics.java:265) topics.getPartitionedTopicMetadata( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetPartitionedTopicMetadataCmd.run(CmdTopics.java:430) topics.deletePartitionedTopic( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DeletePartitionedCmd.run(CmdTopics.java:452) topics.peekMessages( "persistent://myprop/clust/ns1/ds1", "sub1", 3 ); -> at org.apache.pulsar.admin.cli.CmdTopics$PeekMessages.run(CmdTopics.java:781) topics.enableDeduplication( "persistent://myprop/clust/ns1/ds1", true ); -> at org.apache.pulsar.admin.cli.CmdTopics$EnableDeduplication.run(CmdTopics.java:1282) topics.enableDeduplication( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$DisableDeduplication.run(CmdTopics.java:1295) topics.enableDeduplication( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetDeduplication.run(CmdTopics.java:1317) topics.getReplicatorDispatchRate( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetReplicatorDispatchRate.run(CmdTopics.java:1777) topics.setReplicatorDispatchRate( "persistent://myprop/clust/ns1/ds1", DispatchRate{dispatchThrottlingRateInMsg=10, dispatchThrottlingRateInByte=11, ratePeriodInSecond=12} ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetReplicatorDispatchRate.run(CmdTopics.java:1805) topics.removeReplicatorDispatchRate( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveReplicatorDispatchRate.run(CmdTopics.java:1818) topics.getDeduplicationEnabled( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetDeduplicationEnabled.run(CmdTopics.java:1329) topics.getDeduplicationEnabled( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetDeduplicationEnabled.run(CmdTopics.java:1329) topics.getOffloadPolicies( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetOffloadPolicies.run(CmdTopics.java:1365) topics.removeOffloadPolicies( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveOffloadPolicies.run(CmdTopics.java:1377) topics.getDelayedDeliveryPolicy( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetDelayedDelivery.run(CmdTopics.java:1088) topics.setDelayedDeliveryPolicy( "persistent://myprop/clust/ns1/ds1", DelayedDeliveryPolicies(tickTime=10000, active=true) ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetDelayedDelivery.run(CmdTopics.java:1116) topics.removeDelayedDeliveryPolicy( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveDelayedDelivery.run(CmdTopics.java:1128) topics.setOffloadPolicies( "persistent://myprop/clust/ns1/ds1", OffloadPolicies{managedLedgerOffloadedReadPriority=tiered-storage-first, managedLedgerOffloadDriver=s3, managedLedgerOffloadMaxThreads=2, managedLedgerOffloadPrefetchRounds=1, managedLedgerOffloadAutoTriggerSizeThresholdBytes=10, managedLedgerOffloadDeletionLagInMillis=null, s3ManagedLedgerOffloadRegion=region, s3ManagedLedgerOffloadBucket=bucket, s3ManagedLedgerOffloadServiceEndpoint=endpoint, s3ManagedLedgerOffloadMaxBlockSizeInBytes=8, s3ManagedLedgerOffloadReadBufferSizeInBytes=9, s3ManagedLedgerOffloadRole=null, s3ManagedLedgerOffloadRoleSessionName=pulsar-s3-offload, gcsManagedLedgerOffloadRegion=null, gcsManagedLedgerOffloadBucket=null, gcsManagedLedgerOffloadMaxBlockSizeInBytes=67108864, gcsManagedLedgerOffloadReadBufferSizeInBytes=1048576, gcsManagedLedgerOffloadServiceAccountKeyFile=null, fileSystemProfilePath=null, fileSystemURI=null, managedLedgerOffloadBucket=bucket, managedLedgerOffloadRegion=region, managedLedgerOffloadServiceEndpoint=endpoint, managedLedgerOffl oadMaxBlockSizeInBytes=8, managedLedgerOffloadReadBufferSizeInBytes=9} ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetOffloadPolicies.run(CmdTopics.java:1453) topics.getMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1559) topics.getMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1559) topics.removeMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1571) topics.removeMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1571) topics.setMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1", 999 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1586) topics.setMaxUnackedMessagesOnConsumer( "persistent://myprop/clust/ns1/ds1", 999 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnConsumer.run(CmdTopics.java:1586) topics.getMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1598) topics.getMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1598) topics.removeMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1610) topics.removeMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1610) topics.setMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1625) topics.setMaxUnackedMessagesOnSubscription( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxUnackedMessagesOnSubscription.run(CmdTopics.java:1625) topics.getMaxMessageSize( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxMessageSize.run(CmdTopics.java:1912) topics.removeMaxMessageSize( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxMessageSize.run(CmdTopics.java:1939) topics.setMaxMessageSize( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxMessageSize.run(CmdTopics.java:1927) topics.getMaxProducers( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxProducers.run(CmdTopics.java:1833) topics.removeMaxProducers( "persistent://myprop/clust/ns1/ds1" ); -> at org.apache.pulsar.admin.cli.CmdTopics$RemoveMaxProducers.run(CmdTopics.java:1860) topics.setMaxProducers( "persistent://myprop/clust/ns1/ds1", 99 ); -> at org.apache.pulsar.admin.cli.CmdTopics$SetMaxProducers.run(CmdTopics.java:1848) topics.getMaxConsumers( "persistent://myprop/clust/ns1/ds1", false ); -> at org.apache.pulsar.admin.cli.CmdTopics$GetMaxConsumers.run(CmdTopics.java:2058) at org.apache.pulsar.admin.cli.PulsarAdminToolTest.topics(PulsarAdminToolTest.java:858) at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:132) at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:45) at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:73) at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:11) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) </pre></code> </details> ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
