[FLINK-34102][configuration] Fix the invalid configuration when using…

… 'env.log.max' on yarn deployment mode
Gerrrr · Jan 17, 2024 · a20d57b · a20d57b
1 parent eb6d6ff
commit a20d57b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
@@ -207,6 +207,7 @@ public YarnClusterDescriptor(
         this.userJarInclusion = getUserJarInclusionMode(flinkConfiguration);
 
         adaptEnvSetting(flinkConfiguration, CoreOptions.FLINK_LOG_LEVEL, "ROOT_LOG_LEVEL");
+        adaptEnvSetting(flinkConfiguration, CoreOptions.FLINK_LOG_MAX, "MAX_LOG_FILE_NUMBER");
 
         getLocalFlinkDistPath(flinkConfiguration).ifPresent(this::setLocalJarPath);
         decodeFilesToShipToCluster(flinkConfiguration, YarnConfigOptions.SHIP_FILES)