[hotfix] Remove 'TaskManager' from MemoryBackwardsCompatibilityUtils#…

…getLegacyTaskManagerHeapMemoryIfExplicitlyConfigured
bbejeck · Apr 27, 2020 · 4385fcc · 4385fcc
1 parent 679cd0f
commit 4385fcc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...n/java/org/apache/flink/runtime/util/config/memory/MemoryBackwardsCompatibilityUtils.java b/...n/java/org/apache/flink/runtime/util/config/memory/MemoryBackwardsCompatibilityUtils.java
@@ -49,7 +49,7 @@ public Configuration getConfWithLegacyHeapSizeMappedToNewConfigOption(
  if (configuration.contains(configOption)) {
  return configuration;
  }
- return getLegacyTaskManagerHeapMemoryIfExplicitlyConfigured(configuration)
+ return getLegacyHeapMemoryIfExplicitlyConfigured(configuration)
  .map(legacyHeapSize -> {
  Configuration copiedConfig = new Configuration(configuration);
  copiedConfig.set(configOption, legacyHeapSize);
@@ -61,7 +61,7 @@ public Configuration getConfWithLegacyHeapSizeMappedToNewConfigOption(
  }).orElse(configuration);
  }
 
- private Optional<MemorySize> getLegacyTaskManagerHeapMemoryIfExplicitlyConfigured(Configuration configuration) {
+ private Optional<MemorySize> getLegacyHeapMemoryIfExplicitlyConfigured(Configuration configuration) {
  @SuppressWarnings("CallToSystemGetenv")
  String totalProcessEnv = System.getenv(legacyMemoryOptions.getEnvVar());
  if (totalProcessEnv != null) {