|
@@ -64,9 +64,9 @@ public class FlinkArgsUtils {
|
|
|
args.add(ArgsUtils.escape(appName));
|
|
|
}
|
|
|
|
|
|
-
|
|
|
+
|
|
|
String flinkVersion = param.getFlinkVersion();
|
|
|
- if (FLINK_VERSION_BEFORE_1_10.equals(flinkVersion)) {
|
|
|
+ if (flinkVersion == null || FLINK_VERSION_BEFORE_1_10.equals(flinkVersion)) {
|
|
|
int taskManager = param.getTaskManager();
|
|
|
if (taskManager != 0) {
|
|
|
args.add(Constants.FLINK_TASK_MANAGE);
|