pulsar-client-cpp
pulsar-client-cpp copied to clipboard
[issue] run ./pulsar-tests with main branch use 2.11.0 pulsar docker image throw exception
Search before asking
- [X] I searched in the issues and found nothing similar.
Version
pulsar: apachepulsar/pulsar:2.11.0 os : mac 12.6 cpp client version : main branch
Minimal reproduce step
- ./pulsar-test-service-start.sh
- cd tests
- ./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 | [<none> -> 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!