apache / apache/pulsar-client-cpp
[issue] run ./pulsar-tests with main branch use 2.11.0 pulsar docker image throw exception
- Langage dominant
- C++
- Étoiles
- 71
- Forks
- 90
- Merge moyen
- 2 h 33 min
- PR mergées (30 j)
- 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!
Guide de contribution
Ouvrir le guide de contribution
Piste de recherche
Reproduire avec ./pulsar-test-service-start.sh, puis exécuter ./pulsar-tests depuis tests avec apachepulsar/pulsar:2.11.0. Se concentrer sur BasicEndToEndTest.testMessageListenerPause et sur la condition_variable exception affichée après la création du deuxième consommateur. C’est terminé lorsque ce test et l’ensemble de la suite de tests se terminent correctement sans abandonner.
Rédigé par le modèle d'indexation à partir du texte de l'issue.
Évaluation
- Stack technique
- cpp, docker
- Domaine
- distributed-systems, testing
- Type d'issue
- Bug
- Difficulté
- 4/5
- Temps estimé
- 3-5 jours
- Activité
- À l'abandon
- Clarté
- Plutôt claire
- Accessibilité débutants
- 38/100