apache / apache/pulsar-client-cpp

[issue] run ./pulsar-tests with main branch use 2.11.0 pulsar docker image throw exception

Open
#192 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
C++
Stars
71
Forks
90
Avg merge
2h 33m
Merged PRs (30d)
3

Description

### Search before asking

- [X] I searched in the [issues](https://github.com/apache/pulsar-client-cpp/issues) and found nothing similar.

### Version

pulsar: apachepulsar/pulsar:2.11.0
os : mac 12.6
cpp client version : main branch

### Minimal reproduce step

1. ./pulsar-test-service-start.sh
2. cd tests
3. ./pulsar-tests

### What did you expect to see?

run all tests successful

### What did you see instead?

```
[ OK ] BasicEndToEndTest.testMessageListener (5315 ms)
[ RUN ] BasicEndToEndTest.testMessageListenerPause
2023-02-13 15:15:32.932 INFO [0x1049c4580] BasicEndToEndTest:922 | res = 204
2023-02-13 15:15:32.933 INFO [0x1049c4580] ClientConnection:191 | [ -> pulsar://localhost:6650] Create ClientConnection, timeout=10000
2023-02-13 15:15:32.933 INFO [0x1049c4580] ConnectionPool:97 | Created connection for pulsar://localhost:6650
2023-02-13 15:15:32.934 INFO [0x16c7c3000] ClientConnection:389 | [[::1]:51554 -> [::1]:6650] Connected to broker
2023-02-13 15:15:32.945 INFO [0x16c7c3000] HandlerBase:72 | [persistent://public/default/partition-testMessageListenerPause, ] Getting connection from pool
2023-02-13 15:15:32.979 INFO [0x16c7c3000] ProducerImpl:204 | [persistent://public/default/partition-testMessageListenerPause, ] Created producer on broker [[::1]:51554 -> [::1]:6650]
2023-02-13 15:15:32.979 INFO [0x1049c4580] Client:87 | Subscribing on Topic :partition-testMessageListenerPause
2023-02-13 15:15:32.982 INFO [0x16c7c3000] HandlerBase:72 | [persistent://public/default/partition-testMessageListenerPause, subscription-name, 0] Getting connection from pool
2023-02-13 15:15:33.002 INFO [0x16c7c3000] ConsumerImpl:257 | [persistent://public/default/partition-testMessageListenerPause, subscription-name, 0] Created consumer on broker [[::1]:51554 -> [::1]:6650]
2023-02-13 15:15:33.002 INFO [0x1049c4580] ConsumerImpl:309 | [persistent://public/default/partition-testMessageListenerPause, subscription-name, 0] Unsubscribing
2023-02-13 15:15:33.009 INFO [0x16c7c3000] ConsumerImpl:314 | [persistent://public/default/partition-testMessageListenerPause, subscription-name, 0] Unsubscribed successfully
2023-02-13 15:15:33.009 INFO [0x1049c4580] Client:87 | Subscribing on Topic :partition-testMessageListenerPause
2023-02-13 15:15:33.012 INFO [0x16c7c3000] HandlerBase:72 | [persistent://public/default/partition-testMessageListenerPause, subscription-name, 1] Getting connection from pool
2023-02-13 15:15:33.030 INFO [0x16c7c3000] ConsumerImpl:257 | [persistent://public/default/partition-testMessageListenerPause, subscription-name, 1] Created consumer on broker [[::1]:51554 -> [::1]:6650]
libc++abi: terminating with uncaught exception of type std::__1::system_error: condition_variable wait failed: Invalid argument
[6] 3453 abort ./pulsar-tests
➜ tests git:(main) ✗ ls
```

topic stats
```
./pulsar-admin topics stats partition-testMessageListenerPause
{
"msgRateIn" : 0.0,
"msgThroughputIn" : 0.0,
"msgRateOut" : 0.0,
"msgThroughputOut" : 0.0,
"bytesInCounter" : 16928,
"msgInCounter" : 358,
"bytesOutCounter" : 16832,
"msgOutCounter" : 356,
"averageMsgSize" : 0.0,
"msgChunkPublished" : false,
"storageSize" : 16928,
"backlogSize" : 854,
"publishRateLimitedTimes" : 0,
"earliestMsgPublishTimeInBacklogs" : 0,
"offloadedStorageSize" : 0,
"lastOffloadLedgerId" : 0,
"lastOffloadSuccessTimeStamp" : 0,
"lastOffloadFailureTimeStamp" : 0,
"publishers" : [ ],
"waitingPublishers" : 0,
"subscriptions" : {
"subscription-name" : {
"msgRateOut" : 0.0,
"msgThroughputOut" : 0.0,
"bytesOutCounter" : 16832,
"msgOutCounter" : 356,
"msgRateRedeliver" : 0.0,
"messageAckRate" : 0.0,
"chunkedMessageRate" : 0,
"msgBacklog" : 16,
"backlogSize" : 0,
"earliestMsgPublishTimeInBacklog" : 0,
"msgBacklogNoDelayed" : 16,
"blockedSubscriptionOnUnackedMsgs" : false,
"msgDelayed" : 0,
"unackedMessages" : 0,
"type" : "Exclusive",
"msgRateExpired" : 0.0,
"totalMsgExpired" : 0,
"lastExpireTimestamp" : 0,
"lastConsumedFlowTimestamp" : 1676272533027,
"lastConsumedTimestamp" : 0,
"lastAckedTimestamp" : 0,
"lastMarkDeleteAdvancedTimestamp" : 1676272536420,
"consumers" : [ ],
"isDurable" : true,
"isReplicated" : false,
"allowOutOfOrderDelivery" : false,
"consumersAfterMarkDeletePosition" : { },
"nonContiguousDeletedMessagesRanges" : 0,
"nonContiguousDeletedMessagesRangesSerializedSize" : 0,
"delayedTrackerMemoryUsage" : 0,
"subscriptionProperties" : { },
"filterProcessedMsgCount" : 0,
"filterAcceptedMsgCount" : 0,
"filterRejectedMsgCount" : 0,
"filterRescheduledMsgCount" : 0,
"durable" : true,
"replicated" : false
}
},
"replication" : { },
"deduplicationStatus" : "Disabled",
"nonContiguousDeletedMessagesRanges" : 0,
"nonContiguousDeletedMessagesRangesSerializedSize" : 0,
"delayedMessageIndexSizeInBytes" : 0,
"compaction" : {
"lastCompactionRemovedEventCount" : 0,
"lastCompactionSucceedTimestamp" : 0,
"lastCompactionFailedTimestamp" : 0,
"lastCompactionDurationTimeInMills" : 0
}
}
```

### Anything else?

_No response_

### Are you willing to submit a PR?

- [ ] I'm willing to submit a PR!

Contributor guide

Open the contributing guide

Research direction

Reproduce with ./pulsar-test-service-start.sh, then run ./pulsar-tests from tests using apachepulsar/pulsar:2.11.0. Focus on BasicEndToEndTest.testMessageListenerPause and the condition_variable exception shown after the second consumer is created. Done means this test and the full test suite complete successfully without aborting.

Written by the indexing model from the issue text.

Assessment

Tech stack
cpp, docker
Domain
distributed-systems, testing
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
38/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.