[FLINK2392] Increase memory for TaskManager

nltran · Sep 21, 2015 · f5476f2 · f5476f2
1 parent 1ff8d04
commit f5476f2
Showing 1 changed file with 1 addition and 2 deletions.
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
@@ -614,7 +614,7 @@ public void testJavaAPI() {
  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 void testJavaAPI() {
  Thread.sleep(1000);
  } catch (InterruptedException e) {
  LOG.warn("Interrupted", e);
- Thread.interrupted();
  }
  FlinkYarnClusterStatus status = yarnCluster.getClusterStatus();
  if(status != null && status.equals(expectedStatus)) {