From faa454a5543d23f972b79b8091f461f05c0f3452 Mon Sep 17 00:00:00 2001
From: fschueler <fschueler@posteo.de>
Date: Wed, 27 Apr 2016 17:08:34 +0200
Subject: [PATCH] Memory estimate for broadcast updated

---
 .../runtime/controlprogram/context/FlinkExecutionContext.java   | 2 +-
 1 file changed, 1 insertion(+), 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
index bd5d1640ece..93277a8df0e 100644
--- 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() {