Fix typo in TaskManagerConfig

It was re-using the sink buffer size for the driver partitioning buffer size
trinodb · Apr 19, 2016 · 2550e5e · 2550e5e
1 parent 3b99767
commit 2550e5e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/presto-main/src/main/java/com/facebook/presto/execution/TaskManagerConfig.java b/presto-main/src/main/java/com/facebook/presto/execution/TaskManagerConfig.java
@@ -222,7 +222,7 @@ public TaskManagerConfig setSinkMaxBufferSize(DataSize sinkMaxBufferSize)
     @NotNull
     public DataSize getMaxPagePartitioningBufferSize()
     {
-        return sinkMaxBufferSize;
+        return maxPagePartitioningBufferSize;
     }
 
     @Config("driver.max-page-partitioning-buffer-size")

diff --git a/presto-main/src/test/java/com/facebook/presto/execution/TestTaskManagerConfig.java b/presto-main/src/test/java/com/facebook/presto/execution/TestTaskManagerConfig.java
@@ -97,7 +97,7 @@ public void testExplicitPropertyMappings()
                 .setInfoMaxAge(new Duration(22, TimeUnit.MINUTES))
                 .setClientTimeout(new Duration(10, TimeUnit.SECONDS))
                 .setSinkMaxBufferSize(new DataSize(42, Unit.MEGABYTE))
-                .setMaxPagePartitioningBufferSize(new DataSize(42, Unit.MEGABYTE))
+                .setMaxPagePartitioningBufferSize(new DataSize(40, Unit.MEGABYTE))
                 .setWriterCount(3)
                 .setTaskDefaultConcurrency(7)
                 .setTaskJoinConcurrency(8)