diff --git a/fdbclient/FluentDSampleIngestor.cpp b/fdbclient/FluentDSampleIngestor.cpp index b5ee30876d..55cfc1e79c 100644 --- a/fdbclient/FluentDSampleIngestor.cpp +++ b/fdbclient/FluentDSampleIngestor.cpp @@ -95,9 +95,9 @@ class SampleSender : public std::enable_shared_from_thisfirst); if (waitState.size() < 32) { - size = waitState.size() + 1; + size += waitState.size() + 1; } else { - size = waitState.size() + 2; + size += waitState.size() + 2; } size += iter->second.second; // 2. allocate the buffer