private List getApplicationClusterArgs()

in flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecorator.java [80:112]

• 27 lines of code
• 7 McCabe index (conditional complexity)

    private List<String> getApplicationClusterArgs() {
        List<String> args = new ArrayList<>();
        args.add(APPLICATION_MODE_ARG);

        String mainClass = kubernetesJobManagerParameters.getMainClass();
        if (mainClass != null) {
            args.add("--job-classname");
            args.add(mainClass);
        }

        Boolean allowNonRestoredState = kubernetesJobManagerParameters.getAllowNonRestoredState();
        if (allowNonRestoredState != null && allowNonRestoredState) {
            args.add("--allowNonRestoredState");
        }

        String savepointPath = kubernetesJobManagerParameters.getSavepointPath();
        if (savepointPath != null) {
            args.add("--fromSavepoint");
            args.add(savepointPath);
        }

        if (kubernetesJobManagerParameters.isHAEnabled()) {
            args.add("--host");
            args.add(POD_IP_ARG);
        }

        List<String> jobSpecArgs = kubernetesJobManagerParameters.getJobSpecArgs();
        if (jobSpecArgs != null) {
            args.addAll(kubernetesJobManagerParameters.getJobSpecArgs());
        }

        return args;
    }