[hotfix] Fix loading of wrong TaskManager class

flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala

@@ -868,7 +868,7 @@ object TaskManager {
         " - Leave config parameter empty or use 0 to let the system choose a port automatically.")
     }
 
-    runTaskManager(taskManagerHostname, actorSystemPort, configuration, classOf[TaskManager])
+    runTaskManager(taskManagerHostname, actorSystemPort, configuration, taskManagerClass)
   }
 
   /**

flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

@@ -52,7 +52,7 @@ public class Utils {
 	
 	private static final Logger LOG = LoggerFactory.getLogger(Utils.class);
 
-	private static final int DEFAULT_HEAP_LIMIT_CAP = 500;
+	private static final int DEFAULT_HEAP_LIMIT_CAP = 700;
 	private static final float DEFAULT_YARN_HEAP_CUTOFF_RATIO = 0.8f;
 
 	/**

flink-yarn/src/test/java/org/apache/flink/yarn/UtilsTests.java

@@ -27,6 +27,6 @@ public class UtilsTests {
 
 		// ASSUMES DEFAULT Configuration values.
 		Assert.assertEquals(800, Utils.calculateHeapSize(1000) );
-		Assert.assertEquals(9500, Utils.calculateHeapSize(10000) );
+		Assert.assertEquals(9300, Utils.calculateHeapSize(10000) );
 	}
 }