(flink) 02/02: [FLINK-34102][configuration] Fix the invalid configuration when using 'env.log.max' on yarn deployment mode

[fanrui]

This is an automated email from the ASF dual-hosted git repository.

fanrui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit a20d57b18bbab93e943d0b64ffb993382697d242
Author: Roc Marshal <flin...@126.com>
AuthorDate: Tue Jan 16 13:22:37 2024 +0800

    [FLINK-34102][configuration] Fix the invalid configuration when using 
'env.log.max' on yarn deployment mode
---
 .../src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java       | 1 +
 1 file changed, 1 insertion(+)

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
index 97e49b8046a..795567bc9f8 100644
--- 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 class YarnClusterDescriptor implements 
ClusterDescriptor<ApplicationId> {
         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)