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

[congbobo184]

Search before asking

• 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

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