apache / apache/pulsar-client-cpp

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

Đang mở
#192 0 bình luận 0 reaction 0 người được giao Xem trên GitHub
Ngôn ngữ chính
C++
Star
71
Fork
90
Merge trung bình
2 giờ 33 phút
Pull request đã merge (30 ngày)
3

Mô tả

### 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!

Hướng dẫn đóng góp

Mở hướng dẫn đóng góp

Hướng nghiên cứu

Tái hiện bằng ./pulsar-test-service-start.sh, sau đó chạy ./pulsar-tests từ tests bằng apachepulsar/pulsar:2.11.0. Tập trung vào BasicEndToEndTest.testMessageListenerPause và condition_variable exception được hiển thị sau khi consumer thứ hai được tạo. Được xem là hoàn tất khi test này và toàn bộ test suite hoàn thành thành công mà không bị abort.

Do mô hình lập chỉ mục viết ra từ nội dung của issue.

Đánh giá

Công nghệ
cpp, docker
Lĩnh vực
distributed-systems, testing
Loại issue
Lỗi
Độ khó
4/5
Thời gian dự kiến
3-5 ngày
Mức độ hoạt động
Đình trệ
Độ rõ ràng
Khá rõ ràng
Mức phù hợp với người mới
38/100

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.