diff --git a/cpp/runtime/buffer/LocalMemoryBufferPool.cpp b/cpp/runtime/buffer/LocalMemoryBufferPool.cpp
index 28bfca682973c9482c75e201f8d8133259329590..128bacafb3bd954a473cf6d3f52c3ccbb4ae68c6 100644
--- a/cpp/runtime/buffer/LocalMemoryBufferPool.cpp
+++ b/cpp/runtime/buffer/LocalMemoryBufferPool.cpp
@@ -18,7 +18,7 @@ namespace datastream {
                                                  int maxNumberOfMemorySegments,
                                                  int numberOfSubpartitions,
                                                  int maxBuffersPerChannel)
-        : LocalBufferPool(numberOfSubpartitions, 1, numberOfRequiredMemorySegments,
+        : LocalBufferPool(numberOfSubpartitions, maxBuffersPerChannel, numberOfRequiredMemorySegments,
                           numberOfRequiredMemorySegments,
                           maxNumberOfMemorySegments, std::make_shared<AvailabilityHelper>()),
           networkMemoryBufferPool(networkMemoryBufferPool),