You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by "poorbarcode (via GitHub)" <gi...@apache.org> on 2023/09/21 11:52:37 UTC

[GitHub] [pulsar] poorbarcode opened a new pull request, #21222: [fix] [broker] fix flaky test auto subscribe patter consumer from broker watcher

poorbarcode opened a new pull request, #21222:
URL: https://github.com/apache/pulsar/pull/21222

   ### Motivation
   
   see: https://github.com/apache/pulsar/actions/runs/6257755998/job/16993960633?pr=21216
   
   ```
     Error:  org.apache.pulsar.client.impl.PatternTopicsConsumerImplTest.testAutoSubscribePatterConsumerFromBrokerWatcher  Time elapsed: 10.152 s  <<< FAILURE!
     org.awaitility.core.ConditionTimeoutException: Assertion condition defined as a org.apache.pulsar.client.impl.PatternTopicsConsumerImplTest expected [4] but found [0] within 10 seconds.
     	at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
     	at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:119)
     	at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:31)
     	at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:985)
     	at org.awaitility.core.ConditionFactory.untilAsserted(ConditionFactory.java:769)
     	at org.apache.pulsar.client.impl.PatternTopicsConsumerImplTest.testAutoSubscribePatterConsumerFromBrokerWatcher(PatternTopicsConsumerImplTest.java:617)
     	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
     	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
     	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
     	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
     	at org.testng.internal.invokers.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:139)
     	at org.testng.internal.invokers.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:47)
     	at org.testng.internal.invokers.InvokeMethodRunnable.call(InvokeMethodRunnable.java:76)
     	at org.testng.internal.invokers.InvokeMethodRunnable.call(InvokeMethodRunnable.java:11)
     	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:833)
     Caused by: java.lang.AssertionError: expected [4] but found [0]
     	at org.testng.Assert.fail(Assert.java:110)
     	at org.testng.Assert.failNotEquals(Assert.java:1577)
     	at org.testng.Assert.assertEqualsImpl(Assert.java:149)
     	at org.testng.Assert.assertEquals(Assert.java:131)
     	at org.testng.Assert.assertEquals(Assert.java:1418)
     	at org.testng.Assert.assertEquals(Assert.java:1382)
     	at org.testng.Assert.assertEquals(Assert.java:1428)
     	at org.apache.pulsar.client.impl.PatternTopicsConsumerImplTest.lambda$testAutoSubscribePatterConsumerFromBrokerWatcher$16(PatternTopicsConsumerImplTest.java:618)
     	at org.awaitility.core.AssertionCondition.lambda$new$0(AssertionCondition.java:53)
     	at org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:248)
     	at org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:235)
     	... 4 more
   ```
   
   If the new topic is created before the consumer's topic list watcher is connected, the watcher cannot accept the notifications of new topic creation.
   
   ### Modifications
   
   - Make new topics creation start after the consumer's topic list watcher is connected
   - Since the config `subscriptionPatternMaxLength`'s default value is `50`, the pattern name in the test might be too long. So set `subscriptionPatternMaxLength` to a larger value.
   
   
   
   ### Documentation
   
   <!-- DO NOT REMOVE THIS SECTION. CHECK THE PROPER BOX ONLY. -->
   
   - [ ] `doc` <!-- Your PR contains doc changes. -->
   - [ ] `doc-required` <!-- Your PR changes impact docs and you will update later -->
   - [x] `doc-not-needed` <!-- Your PR changes do not impact docs -->
   - [ ] `doc-complete` <!-- Docs have been already added -->
   
   ### Matching PR in forked repository
   
   PR in forked repository: x


-- 
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: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [pulsar] codecov-commenter commented on pull request #21222: [fix] [broker] fix flaky test auto subscribe patter consumer from broker watcher

Posted by "codecov-commenter (via GitHub)" <gi...@apache.org>.
codecov-commenter commented on PR #21222:
URL: https://github.com/apache/pulsar/pull/21222#issuecomment-1730841718

   ## [Codecov](https://app.codecov.io/gh/apache/pulsar/pull/21222?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) Report
   > Merging [#21222](https://app.codecov.io/gh/apache/pulsar/pull/21222?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) (4d7378c) into [master](https://app.codecov.io/gh/apache/pulsar/commit/66271e3bf3cf0699789c759d852c24e6f00f90cd?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) (66271e3) will **increase** coverage by `0.46%`.
   > Report is 1 commits behind head on master.
   > The diff coverage is `n/a`.
   
   [![Impacted file tree graph](https://app.codecov.io/gh/apache/pulsar/pull/21222/graphs/tree.svg?width=650&height=150&src=pr&token=acYqCpsK9J&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)](https://app.codecov.io/gh/apache/pulsar/pull/21222?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
   
   ```diff
   @@             Coverage Diff              @@
   ##             master   #21222      +/-   ##
   ============================================
   + Coverage     72.73%   73.20%   +0.46%     
   - Complexity    32465    32479      +14     
   ============================================
     Files          1875     1887      +12     
     Lines        139929   140118     +189     
     Branches      15413    15426      +13     
   ============================================
   + Hits         101781   102570     +789     
   + Misses        30067    29457     -610     
   - Partials       8081     8091      +10     
   ```
   
   | [Flag](https://app.codecov.io/gh/apache/pulsar/pull/21222/flags?src=pr&el=flags&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | Coverage Δ | |
   |---|---|---|
   | [inttests](https://app.codecov.io/gh/apache/pulsar/pull/21222/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `24.18% <ø> (+0.01%)` | :arrow_up: |
   | [systests](https://app.codecov.io/gh/apache/pulsar/pull/21222/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `24.74% <ø> (?)` | |
   | [unittests](https://app.codecov.io/gh/apache/pulsar/pull/21222/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `72.51% <ø> (+0.01%)` | :arrow_up: |
   
   Flags with carried forward coverage won't be shown. [Click here](https://docs.codecov.io/docs/carryforward-flags?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#carryforward-flags-in-the-pull-request-comment) to find out more.
   
   [see 154 files with indirect coverage changes](https://app.codecov.io/gh/apache/pulsar/pull/21222/indirect-changes?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
   


-- 
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: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [pulsar] Technoboy- merged pull request #21222: [fix] [broker] fix flaky test PatternTopicsConsumerImplTest

Posted by "Technoboy- (via GitHub)" <gi...@apache.org>.
Technoboy- merged PR #21222:
URL: https://github.com/apache/pulsar/pull/21222


-- 
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: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [pulsar] poorbarcode closed pull request #21222: [fix] [broker] fix flaky test auto subscribe patter consumer from broker watcher

Posted by "poorbarcode (via GitHub)" <gi...@apache.org>.
poorbarcode closed pull request #21222: [fix] [broker] fix flaky test auto subscribe patter consumer from broker watcher
URL: https://github.com/apache/pulsar/pull/21222


-- 
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: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org