We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1a375e8 commit 75516adCopy full SHA for 75516ad
1 file changed
launcher/src/main/java/com/dtstack/flink/sql/launcher/ClusterClientFactory.java
@@ -157,7 +157,7 @@ private static ApplicationId getYarnClusterApplicationId(YarnClient yarnClient)
157
158
}
159
160
- if (StringUtils.isEmpty(applicationId.toString())) {
+ if (applicationId == null || StringUtils.isEmpty(applicationId.toString())) {
161
throw new RuntimeException("No flink session found on yarn cluster.");
162
163
return applicationId;
0 commit comments