This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a commit to branch flip116 in repository https://gitbox.apache.org/repos/asf/flink.git
commit f7000fe78b8be103844e6d1b0c06605559286e65 Author: Andrey Zagrebin <[email protected]> AuthorDate: Thu Apr 9 12:02:30 2020 +0300 fixup! [FLINK-16745][yarn] Start Yarn JM with FLIP-116 JVM memory args --- .../src/test/java/org/apache/flink/yarn/YARNFileReplicationITCase.java | 2 +- .../src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java | 2 +- flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNFileReplicationITCase.java b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNFileReplicationITCase.java index 5cb9e5f..993adbf 100644 --- a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNFileReplicationITCase.java +++ b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNFileReplicationITCase.java @@ -132,7 +132,7 @@ public class YARNFileReplicationITCase extends YarnTestBase { private Configuration getDefaultConfiguration() { final Configuration configuration = new Configuration(); - configuration.set(JobManagerOptions.TOTAL_PROCESS_MEMORY, MemorySize.parse("1g")); + configuration.set(JobManagerOptions.TOTAL_PROCESS_MEMORY, MemorySize.ofMebiBytes(768)); configuration.set(TaskManagerOptions.TOTAL_PROCESS_MEMORY, MemorySize.parse("1g")); configuration.setString(AkkaOptions.ASK_TIMEOUT, "30 s"); configuration.setString(CLASSPATH_INCLUDE_USER_JAR, YarnConfigOptions.UserJarInclusion.DISABLED.toString()); diff --git a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java index 41d0cf4..a8b799a 100644 --- a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java +++ b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java @@ -273,7 +273,7 @@ public class YARNHighAvailabilityITCase extends YarnTestBase { @Nonnull private YarnClusterDescriptor setupYarnClusterDescriptor() { final Configuration flinkConfiguration = new Configuration(); - flinkConfiguration.set(JobManagerOptions.TOTAL_PROCESS_MEMORY, MemorySize.parse("1g")); + flinkConfiguration.set(JobManagerOptions.TOTAL_PROCESS_MEMORY, MemorySize.ofMebiBytes(768)); flinkConfiguration.set(TaskManagerOptions.TOTAL_PROCESS_MEMORY, MemorySize.parse("1g")); flinkConfiguration.setString(YarnConfigOptions.APPLICATION_ATTEMPTS, "10"); flinkConfiguration.setString(HighAvailabilityOptions.HA_MODE, "zookeeper"); diff --git a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java index da51e3c..b7139af 100644 --- a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java +++ b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java @@ -140,7 +140,7 @@ public class YARNITCase extends YarnTestBase { private Configuration createDefaultConfiguration(YarnConfigOptions.UserJarInclusion userJarInclusion) { Configuration configuration = new Configuration(); - configuration.set(JobManagerOptions.TOTAL_PROCESS_MEMORY, MemorySize.parse("1g")); + configuration.set(JobManagerOptions.TOTAL_PROCESS_MEMORY, MemorySize.ofMebiBytes(768)); configuration.set(TaskManagerOptions.TOTAL_PROCESS_MEMORY, MemorySize.parse("1g")); configuration.setString(AkkaOptions.ASK_TIMEOUT, "30 s"); configuration.setString(CLASSPATH_INCLUDE_USER_JAR, userJarInclusion.toString());
