private String[] genProgramArgs(FlinkInfo flinkInfo, FlinkConfig flinkConfig) {
        List<String> list = new ArrayList<>();
        list.add("-cluster-id");
        list.add(flinkInfo.getJobName());
        list.add("-job.name");
        list.add(flinkInfo.getJobName());
        list.add("-group.info.file");
        list.add(flinkInfo.getLocalConfPath());
        list.add("-checkpoint.interval");
        list.add("60000");
        if (InlongConstants.RUNTIME_EXECUTION_MODE_BATCH.equalsIgnoreCase(flinkInfo.getRuntimeExecutionMode())) {
            list.add("-runtime.execution.mode");
            list.add(flinkInfo.getRuntimeExecutionMode());
            list.add("-source.boundary.type");
            list.add(flinkInfo.getBoundaryType());
            list.add("-source.lower.boundary");
            list.add(flinkInfo.getLowerBoundary());
            list.add("-source.upper.boundary");
            list.add(flinkInfo.getUpperBoundary());
        }
        return list.toArray(new String[0]);
    }
Build the program of the Flink job.
inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkService.java