diff --git a/arangod/Pregel/OutgoingCache.cpp b/arangod/Pregel/OutgoingCache.cpp index 030f11d60f..8f43a49e42 100644 --- a/arangod/Pregel/OutgoingCache.cpp +++ b/arangod/Pregel/OutgoingCache.cpp @@ -81,6 +81,10 @@ void ArrayOutCache::appendMessage(prgl_shard_t shard, std::string const& key, template void ArrayOutCache::flushMessages() { + if (this->_containedMessages == 0) { + return; + } + // LOG_TOPIC(INFO, Logger::PREGEL) << "Beginning to send messages to other // machines"; uint64_t gss = this->_config->globalSuperstep(); @@ -189,6 +193,10 @@ void CombiningOutCache::appendMessage(prgl_shard_t shard, template void CombiningOutCache::flushMessages() { + if (this->_containedMessages == 0) { + return; + } + // LOG_TOPIC(INFO, Logger::PREGEL) << "Beginning to send messages to other // machines"; uint64_t gss = this->_config->globalSuperstep();