[flink] 15/16: [hotfix] ignore empty yarn properties

[kkloudas]

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

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

commit 6d67d18e33ed3abbe5af864b82be5b1d19bf5ebb
Author: Kostas Kloudas <kklou...@gmail.com>
AuthorDate: Sun Nov 17 16:50:18 2019 +0100

    [hotfix] ignore empty yarn properties
---
 .../src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java 
b/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
index 8c0a391..388dea0 100644
--- 
a/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
+++ 
b/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
@@ -420,7 +420,9 @@ public class FlinkYarnSessionCli extends 
AbstractCustomCommandLine {
                }
 
                final String dynamicPropertiesEncoded = 
encodeDynamicProperties(commandLine);
-               
configuration.setString(YarnConfigOptionsInternal.DYNAMIC_PROPERTIES, 
dynamicPropertiesEncoded);
+               if (dynamicPropertiesEncoded != null && 
!dynamicPropertiesEncoded.isEmpty()) {
+                       
configuration.setString(YarnConfigOptionsInternal.DYNAMIC_PROPERTIES, 
dynamicPropertiesEncoded);
+               }
 
                final boolean detached = 
commandLine.hasOption(YARN_DETACHED_OPTION.getOpt()) || 
commandLine.hasOption(DETACHED_OPTION.getOpt());
                configuration.setBoolean(DeploymentOptions.ATTACHED, !detached);