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 2019/08/06 01:31:36 UTC
[GitHub] [pulsar] sijie opened a new issue #4894:
ConsumerStatsTest.testAsyncCallOnPartitionedTopic is flaky
sijie opened a new issue #4894: ConsumerStatsTest.testAsyncCallOnPartitionedTopic is flaky
URL: https://github.com/apache/pulsar/issues/4894
```
2019-08-05 13:46:30.473 INFO ConsumerStatsTest:246 | res = 204
2019-08-05 13:46:30.473 INFO Client:88 | Subscribing on Topic :persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788
2019-08-05 13:46:30.475 INFO ConnectionPool:72 | Created connection for pulsar://localhost:6650
2019-08-05 13:46:30.476 INFO ClientConnection:324 | [127.0.0.1:41422 -> 127.0.0.1:6650] Connected to broker
2019-08-05 13:46:30.662 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-0, subscription-name, 0] Getting connection from pool
2019-08-05 13:46:30.663 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-1, subscription-name, 1] Getting connection from pool
2019-08-05 13:46:30.663 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-2, subscription-name, 2] Getting connection from pool
2019-08-05 13:46:30.663 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-3, subscription-name, 3] Getting connection from pool
2019-08-05 13:46:30.664 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-4, subscription-name, 4] Getting connection from pool
2019-08-05 13:46:30.664 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-5, subscription-name, 5] Getting connection from pool
2019-08-05 13:46:30.664 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-6, subscription-name, 6] Getting connection from pool
2019-08-05 13:46:31.909 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-2, subscription-name, 2] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:32.010 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-3, subscription-name, 3] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:32.069 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-5, subscription-name, 5] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:32.069 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-0, subscription-name, 0] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:32.069 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-4, subscription-name, 4] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:32.069 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-1, subscription-name, 1] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:32.171 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-6, subscription-name, 6] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:32.172 INFO PartitionedConsumerImpl:252 | Successfully Subscribed to Partitioned Topic - persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788 with - 7 Partitions.
2019-08-05 13:46:32.172 INFO PartitionedConsumerImpl:121 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788,subscription-name] Unsubscribing
2019-08-05 13:46:32.172 INFO ConsumerImpl:222 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-0, subscription-name, 0] Unsubscribing
2019-08-05 13:46:32.172 INFO ConsumerImpl:222 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-1, subscription-name, 1] Unsubscribing
2019-08-05 13:46:32.172 INFO ConsumerImpl:222 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-2, subscription-name, 2] Unsubscribing
2019-08-05 13:46:32.172 INFO ConsumerImpl:222 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-3, subscription-name, 3] Unsubscribing
2019-08-05 13:46:32.172 INFO ConsumerImpl:222 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-4, subscription-name, 4] Unsubscribing
2019-08-05 13:46:32.173 INFO ConsumerImpl:222 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-5, subscription-name, 5] Unsubscribing
2019-08-05 13:46:32.173 INFO ConsumerImpl:222 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-6, subscription-name, 6] Unsubscribing
2019-08-05 13:46:32.409 INFO ConsumerImpl:255 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-0, subscription-name, 0] Unsubscribed successfully
2019-08-05 13:46:32.409 INFO PartitionedConsumerImpl:165 | Successfully Unsubscribed Consumer - 0 for Subscription - subscription-name for Topic - persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788
2019-08-05 13:46:32.412 INFO ConsumerImpl:255 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-1, subscription-name, 1] Unsubscribed successfully
2019-08-05 13:46:32.412 INFO PartitionedConsumerImpl:165 | Successfully Unsubscribed Consumer - 1 for Subscription - subscription-name for Topic - persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788
2019-08-05 13:46:32.412 INFO ConsumerImpl:255 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-2, subscription-name, 2] Unsubscribed successfully
2019-08-05 13:46:32.413 INFO PartitionedConsumerImpl:165 | Successfully Unsubscribed Consumer - 2 for Subscription - subscription-name for Topic - persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788
2019-08-05 13:46:32.413 INFO ConsumerImpl:255 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-3, subscription-name, 3] Unsubscribed successfully
2019-08-05 13:46:32.413 INFO PartitionedConsumerImpl:165 | Successfully Unsubscribed Consumer - 3 for Subscription - subscription-name for Topic - persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788
2019-08-05 13:46:32.413 INFO ConsumerImpl:255 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-4, subscription-name, 4] Unsubscribed successfully
2019-08-05 13:46:32.413 INFO PartitionedConsumerImpl:165 | Successfully Unsubscribed Consumer - 4 for Subscription - subscription-name for Topic - persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788
2019-08-05 13:46:32.415 INFO ConsumerImpl:255 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-6, subscription-name, 6] Unsubscribed successfully
2019-08-05 13:46:32.415 INFO PartitionedConsumerImpl:165 | Successfully Unsubscribed Consumer - 6 for Subscription - subscription-name for Topic - persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788
2019-08-05 13:46:32.415 INFO ConsumerImpl:255 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-5, subscription-name, 5] Unsubscribed successfully
2019-08-05 13:46:32.415 INFO PartitionedConsumerImpl:165 | Successfully Unsubscribed Consumer - 5 for Subscription - subscription-name for Topic - persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788
2019-08-05 13:46:32.415 INFO Client:88 | Subscribing on Topic :persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788
2019-08-05 13:46:32.418 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-0, subscription-name, 7] Getting connection from pool
2019-08-05 13:46:32.418 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-1, subscription-name, 8] Getting connection from pool
2019-08-05 13:46:32.419 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-2, subscription-name, 9] Getting connection from pool
2019-08-05 13:46:32.419 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-3, subscription-name, 10] Getting connection from pool
2019-08-05 13:46:32.419 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-4, subscription-name, 11] Getting connection from pool
2019-08-05 13:46:32.420 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-5, subscription-name, 12] Getting connection from pool
2019-08-05 13:46:32.420 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-6, subscription-name, 13] Getting connection from pool
2019-08-05 13:46:33.204 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-0, subscription-name, 7] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.204 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-4, subscription-name, 11] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.204 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-6, subscription-name, 13] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.206 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-5, subscription-name, 12] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.208 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-2, subscription-name, 9] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.212 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-1, subscription-name, 8] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.212 INFO ConsumerImpl:170 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-3, subscription-name, 10] Created consumer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.212 INFO PartitionedConsumerImpl:252 | Successfully Subscribed to Partitioned Topic - persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788 with - 7 Partitions.
2019-08-05 13:46:33.220 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-0, ] Getting connection from pool
2019-08-05 13:46:33.220 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-1, ] Getting connection from pool
2019-08-05 13:46:33.220 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-2, ] Getting connection from pool
2019-08-05 13:46:33.221 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-3, ] Getting connection from pool
2019-08-05 13:46:33.221 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-4, ] Getting connection from pool
2019-08-05 13:46:33.221 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-5, ] Getting connection from pool
2019-08-05 13:46:33.221 INFO HandlerBase:52 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-6, ] Getting connection from pool
2019-08-05 13:46:33.355 INFO ProducerImpl:155 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-6, ] Created producer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.356 INFO ProducerImpl:155 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-5, ] Created producer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.356 INFO ProducerImpl:155 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-4, ] Created producer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.356 INFO ProducerImpl:155 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-3, ] Created producer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.360 INFO ProducerImpl:155 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-1, ] Created producer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.362 INFO ProducerImpl:155 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-2, ] Created producer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
2019-08-05 13:46:33.363 INFO ProducerImpl:155 | [persistent://public/default/testAsyncCallOnPartitionedTopic-1565012788-partition-0, ] Created producer on broker [127.0.0.1:41422 -> 127.0.0.1:6650]
/pulsar/pulsar-client-cpp/tests/ConsumerStatsTest.cc:48: Failure
Value of: statsPtr->getBrokerConsumerStats(index).getMsgBacklog()
Actual: 10
Expected: expectedBacklog
Which is: 5
/pulsar/pulsar-client-cpp/tests/ConsumerStatsTest.cc:315: Failure
Value of: latch.wait(std::chrono::seconds(10))
Actual: false
Expected: true
[0;31m[ FAILED ] [mConsumerStatsTest.testAsyncCallOnPartitionedTopic (30469 ms)
[0;32m[----------] [m1 test from ConsumerStatsTest (30470 ms total)
[0;32m[----------] [mGlobal test environment tear-down
[0;32m[==========] [m1 test from 1 test case ran. (30470 ms total)
[0;32m[ PASSED ] [m0 tests.
[0;31m[ FAILED ] [m1 test, listed below:
[0;31m[ FAILED ] [mConsumerStatsTest.testAsyncCallOnPartitionedTopic
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
With regards,
Apache Git Services