You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2020/07/09 22:49:07 UTC

[GitHub] [pulsar] merlimat commented on pull request #7487: [C++] Add unit tests for key shared consumer

merlimat commented on pull request #7487:
URL: https://github.com/apache/pulsar/pull/7487#issuecomment-656387913


   @BewareMyPower The unit test is actually flaky:
   
   
   ```
    [136/168] KeySharedConsumerTest.testNonPartitionedTopic (3178 ms)
    Note: Google Test filter = KeySharedConsumerTest.testNonPartitionedTopic
    [==========] Running 1 test from 1 test case.
    [----------] Global test environment set-up.
    [----------] 1 test from KeySharedConsumerTest
    [ RUN      ] KeySharedConsumerTest.testNonPartitionedTopic
    2020-07-09 22:35:43.677 INFO  [140674701663232] ConnectionPool:85 | Created connection for pulsar://localhost:6650
    2020-07-09 22:35:43.678 INFO  [140674540517120] ClientConnection:335 | [127.0.0.1:49778 -> 127.0.0.1:6650] Connected to broker
    2020-07-09 22:35:43.681 INFO  [140674540517120] HandlerBase:53 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, ] Getting connection from pool
    2020-07-09 22:35:43.691 INFO  [140674540517120] ProducerImpl:165 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, ] Created producer on broker [127.0.0.1:49778 -> 127.0.0.1:6650]
    2020-07-09 22:35:43.691 INFO  [140674701663232] Client:88 | Subscribing on Topic :KeySharedConsumerTest-non-par-topic1594334143
    2020-07-09 22:35:43.694 INFO  [140674540517120] HandlerBase:53 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, SubscriptionName, 0] Getting connection from pool
    2020-07-09 22:35:43.703 INFO  [140674540517120] ConsumerImpl:199 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, SubscriptionName, 0] Created consumer on broker [127.0.0.1:49778 -> 127.0.0.1:6650]
    2020-07-09 22:35:43.703 INFO  [140674701663232] Client:88 | Subscribing on Topic :KeySharedConsumerTest-non-par-topic1594334143
    2020-07-09 22:35:43.704 INFO  [140674540517120] HandlerBase:53 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, SubscriptionName, 1] Getting connection from pool
    2020-07-09 22:35:43.706 INFO  [140674540517120] ConsumerImpl:199 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, SubscriptionName, 1] Created consumer on broker [127.0.0.1:49778 -> 127.0.0.1:6650]
    2020-07-09 22:35:43.706 INFO  [140674701663232] Client:88 | Subscribing on Topic :KeySharedConsumerTest-non-par-topic1594334143
    2020-07-09 22:35:43.707 INFO  [140674540517120] HandlerBase:53 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, SubscriptionName, 2] Getting connection from pool
    2020-07-09 22:35:43.708 INFO  [140674540517120] ConsumerImpl:199 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, SubscriptionName, 2] Created consumer on broker [127.0.0.1:49778 -> 127.0.0.1:6650]
    2020-07-09 22:35:46.830 INFO  [140674701663232] KeySharedConsumerTest:120 | messagesPerConsumer: {0 => 502, 1 => 249, 2 => 249}
    /builds/streamlio/pulsar/pulsar-client-cpp/tests/KeySharedConsumerTest.cc:123: Failure
    Expected: (fabs(count - expectedMessagesPerConsumer)) < (expectedMessagesPerConsumer * PERCENT_ERROR), actual: 168.667 vs 166.667
    2020-07-09 22:35:46.831 INFO  [140674701663232] ClientImpl:481 | Closing Pulsar client
    2020-07-09 22:35:46.831 INFO  [140674701663232] ProducerImpl:502 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, standalone-0-186] Closing producer for topic persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143
    2020-07-09 22:35:46.831 INFO  [140674701663232] ConsumerImpl:866 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, SubscriptionName, 0] Closing consumer for topic persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143
    2020-07-09 22:35:46.831 INFO  [140674701663232] ConsumerImpl:866 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, SubscriptionName, 1] Closing consumer for topic persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143
    2020-07-09 22:35:46.831 INFO  [140674701663232] ConsumerImpl:866 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, SubscriptionName, 2] Closing consumer for topic persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143
    2020-07-09 22:35:46.832 INFO  [140674540517120] ProducerImpl:545 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, standalone-0-186] Closed producer
    2020-07-09 22:35:46.838 INFO  [140674540517120] ConsumerImpl:920 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, SubscriptionName, 0] Closed consumer 0
    2020-07-09 22:35:46.838 INFO  [140674540517120] ConsumerImpl:920 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, SubscriptionName, 1] Closed consumer 1
    2020-07-09 22:35:46.838 INFO  [140674540517120] ConsumerImpl:920 | [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, SubscriptionName, 2] Closed consumer 2
    2020-07-09 22:35:46.838 INFO  [140674540517120] ClientConnection:1372 | [127.0.0.1:49778 -> 127.0.0.1:6650] Connection closed
    2020-07-09 22:35:46.839 INFO  [140674701663232] ProducerImpl:483 | Producer - [persistent://public/default/KeySharedConsumerTest-non-par-topic1594334143, standalone-0-186] , [batching  = off]
    2020-07-09 22:35:46.839 INFO  [140674701663232] ClientConnection:235 | [127.0.0.1:49778 -> 127.0.0.1:6650] Destroyed connection
    [  FAILED  ] KeySharedConsumerTest.testNonPartitionedTopic (3163 ms)
    [----------] 1 test from KeySharedConsumerTest (3163 ms total)
    [----------] Global test environment tear-down
    [==========] 1 test from 1 test case ran. (3163 ms total)
    [  PASSED  ] 0 tests.
    [  FAILED  ] 1 test, listed below:
    [  FAILED  ] KeySharedConsumerTest.testNonPartitionedTopic
     1 FAILED TEST
   ```


----------------------------------------------------------------
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:
users@infra.apache.org