From 923e73c8eb6e2c20d5766d98b9e3a1f51e1c4db2 Mon Sep 17 00:00:00 2001
From: Lijun Ye <294412046@qq.com>
Date: Fri, 22 Feb 2019 11:35:18 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BD=93=E5=AE=A2=E6=88=B7=E7=AB=AF=E6=B2=A1?=
 =?UTF-8?q?=E6=9C=89=E5=90=AF=E5=8A=A8yarn=20session=E7=9A=84=E6=97=B6?=
 =?UTF-8?q?=E5=80=99=E4=BC=9A=E6=8A=A5=E7=A9=BA=E6=8C=87=E9=92=88=E9=94=99?=
 =?UTF-8?q?=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/dtstack/flinkx/launcher/ClusterClientFactory.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flinkx-launcher/src/main/java/com/dtstack/flinkx/launcher/ClusterClientFactory.java b/flinkx-launcher/src/main/java/com/dtstack/flinkx/launcher/ClusterClientFactory.java
index a01cc56432..c3393c40ae 100644
--- a/flinkx-launcher/src/main/java/com/dtstack/flinkx/launcher/ClusterClientFactory.java
+++ b/flinkx-launcher/src/main/java/com/dtstack/flinkx/launcher/ClusterClientFactory.java
@@ -122,7 +122,7 @@ public static ClusterClient createYarnClient(LauncherOptions launcherOptions) {
 
                 }
 
-                if(StringUtils.isEmpty(applicationId.toString())) {
+                if(applicationId != null && StringUtils.isEmpty(applicationId.toString())) {
                     throw new RuntimeException("No flink session found on yarn cluster.");
                 }