Memory estimate for broadcast updated

stratosphere · Apr 27, 2016 · faa454a · faa454a
1 parent 3d30bb0
commit faa454a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/apache/sysml/runtime/controlprogram/context/FlinkExecutionContext.java b/src/main/java/org/apache/sysml/runtime/controlprogram/context/FlinkExecutionContext.java
@@ -437,7 +437,7 @@ public static double getBroadcastMemoryBudget() {
         }
 
 		//70% of remaining free memory, flink uses network buffers for broadcast variables
-		return OptimizerUtils.MEM_UTIL_FACTOR * _memNetworkBuffers;
+		return OptimizerUtils.MEM_UTIL_FACTOR * (_memTaskManagerTotal - _memTaskManagerManaged - _memNetworkBuffers);
 	}
 
     public static double getConfiguredTotalDataMemory() {