flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject flink git commit: [FLINK2392] Increase memory for TaskManager
Date Mon, 21 Sep 2015 11:48:01 GMT
Repository: flink
Updated Branches:
  refs/heads/master 1ff8d04c0 -> f5476f294


[FLINK2392] Increase memory for TaskManager


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f5476f29
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f5476f29
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f5476f29

Branch: refs/heads/master
Commit: f5476f294d280eea73b977e21862fb1c7ad0a2f1
Parents: 1ff8d04
Author: Robert Metzger <rmetzger@apache.org>
Authored: Mon Sep 21 11:27:24 2015 +0200
Committer: Robert Metzger <rmetzger@apache.org>
Committed: Mon Sep 21 13:47:22 2015 +0200

----------------------------------------------------------------------
 .../main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/f5476f29/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
----------------------------------------------------------------------
diff --git a/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
b/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
index 3d381a6..aac9fe1 100644
--- a/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
+++ b/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
@@ -614,7 +614,7 @@ public class YARNSessionFIFOITCase extends YarnTestBase {
 		Assert.assertNotNull("unable to get yarn client", flinkYarnClient);
 		flinkYarnClient.setTaskManagerCount(1);
 		flinkYarnClient.setJobManagerMemory(768);
-		flinkYarnClient.setTaskManagerMemory(768);
+		flinkYarnClient.setTaskManagerMemory(1024);
 		flinkYarnClient.setLocalJarPath(new Path(flinkUberjar.getAbsolutePath()));
 		String confDirPath = System.getenv("FLINK_CONF_DIR");
 		flinkYarnClient.setConfigurationDirectory(confDirPath);
@@ -637,7 +637,6 @@ public class YARNSessionFIFOITCase extends YarnTestBase {
 				Thread.sleep(1000);
 			} catch (InterruptedException e) {
 				LOG.warn("Interrupted", e);
-				Thread.interrupted();
 			}
 			FlinkYarnClusterStatus status = yarnCluster.getClusterStatus();
 			if(status != null && status.equals(expectedStatus)) {


Mime
View raw message