diff --git a/presto-native-execution/presto_cpp/main/Announcer.cpp b/presto-native-execution/presto_cpp/main/Announcer.cpp index 46f7dec2b2046..3c718ea945f1b 100644 --- a/presto-native-execution/presto_cpp/main/Announcer.cpp +++ b/presto-native-execution/presto_cpp/main/Announcer.cpp @@ -166,10 +166,11 @@ void Announcer::scheduleNext() { if (stopped_) { return; } + + auto delayMs_ = frequencyMs_ + folly::Random::rand32(2000) - 1000; eventBaseThread_.getEventBase()->scheduleAt( [this]() { return makeAnnouncement(); }, - std::chrono::steady_clock::now() + - std::chrono::milliseconds(frequencyMs_)); + std::chrono::steady_clock::now() + std::chrono::milliseconds(delayMs_)); } } // namespace facebook::presto