|
|
@ -129,6 +129,8 @@ public class FlinkArgsUtils { |
|
|
|
if (FlinkDeployMode.LOCAL == deployMode) { |
|
|
|
if (FlinkDeployMode.LOCAL == deployMode) { |
|
|
|
// execution.target
|
|
|
|
// execution.target
|
|
|
|
initOptions.add(String.format(FlinkConstants.FLINK_FORMAT_EXECUTION_TARGET, FlinkConstants.FLINK_LOCAL)); |
|
|
|
initOptions.add(String.format(FlinkConstants.FLINK_FORMAT_EXECUTION_TARGET, FlinkConstants.FLINK_LOCAL)); |
|
|
|
|
|
|
|
} else if (FlinkDeployMode.STANDALONE == deployMode) { |
|
|
|
|
|
|
|
// standalone exec
|
|
|
|
} else { |
|
|
|
} else { |
|
|
|
// execution.target
|
|
|
|
// execution.target
|
|
|
|
initOptions.add( |
|
|
|
initOptions.add( |
|
|
@ -209,6 +211,9 @@ public class FlinkArgsUtils { |
|
|
|
case LOCAL: |
|
|
|
case LOCAL: |
|
|
|
args.add(FlinkConstants.FLINK_RUN); // run
|
|
|
|
args.add(FlinkConstants.FLINK_RUN); // run
|
|
|
|
break; |
|
|
|
break; |
|
|
|
|
|
|
|
case STANDALONE: |
|
|
|
|
|
|
|
args.add(FlinkConstants.FLINK_RUN); // run
|
|
|
|
|
|
|
|
break; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
String others = flinkParameters.getOthers(); |
|
|
|
String others = flinkParameters.getOthers(); |
|
|
@ -259,6 +264,8 @@ public class FlinkArgsUtils { |
|
|
|
break; |
|
|
|
break; |
|
|
|
case LOCAL: |
|
|
|
case LOCAL: |
|
|
|
break; |
|
|
|
break; |
|
|
|
|
|
|
|
case STANDALONE: |
|
|
|
|
|
|
|
break; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
int parallelism = flinkParameters.getParallelism(); |
|
|
|
int parallelism = flinkParameters.getParallelism(); |
|
|
|