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

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

commit 318c4add45235d63045c4986cec1372891589a5c
Author: Kostas Kloudas <kklou...@gmail.com>
AuthorDate: Thu Nov 7 13:01:52 2019 +0100

    [hotfix] Make logging flags explicit
---
 .../src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java | 7 +++++--
 1 file changed, 5 insertions(+), 2 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
index 72f6778..ae59d92 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
@@ -950,10 +950,13 @@ public class YarnClusterDescriptor implements 
ClusterDescriptor<ApplicationId> {
                                        "");
                }
 
+               final boolean hasLogback = logConfigFilePath != null && 
logConfigFilePath.endsWith(CONFIG_FILE_LOGBACK_NAME);
+               final boolean hasLog4j = logConfigFilePath != null && 
logConfigFilePath.endsWith(CONFIG_FILE_LOG4J_NAME);
+
                final ContainerLaunchContext amContainer = 
setupApplicationMasterContainer(
                                yarnClusterEntrypoint,
-                               logConfigFilePath != null && 
logConfigFilePath.endsWith(CONFIG_FILE_LOGBACK_NAME),
-                               logConfigFilePath != null && 
logConfigFilePath.endsWith(CONFIG_FILE_LOG4J_NAME),
+                               hasLogback,
+                               hasLog4j,
                                hasKrb5,
                                clusterSpecification.getMasterMemoryMB());
 

Reply via email to