diff --git a/pulsar-client-cpp/lib/PeriodicTask.cc b/pulsar-client-cpp/lib/PeriodicTask.cc index f25a175e4d073..533d38b5efa94 100644 --- a/pulsar-client-cpp/lib/PeriodicTask.cc +++ b/pulsar-client-cpp/lib/PeriodicTask.cc @@ -43,7 +43,7 @@ void PeriodicTask::stop() { } void PeriodicTask::handleTimeout(const ErrorCode& ec) { - if (state_ != Ready) { + if (state_ != Ready || ec.value() == boost::system::errc::operation_canceled) { return; }