diff --git a/dinky-client/dinky-client-base/src/main/java/org/dinky/trans/dml/ExecuteJarOperation.java b/dinky-client/dinky-client-base/src/main/java/org/dinky/trans/dml/ExecuteJarOperation.java index dccd2ab7b7..76afc02a0f 100644 --- a/dinky-client/dinky-client-base/src/main/java/org/dinky/trans/dml/ExecuteJarOperation.java +++ b/dinky-client/dinky-client-base/src/main/java/org/dinky/trans/dml/ExecuteJarOperation.java @@ -91,7 +91,8 @@ public static StreamGraph getStreamGraph(JarSubmitParam submitParam, CustomTable .setSavepointRestoreSettings(savepointRestoreSettings) .setArguments(RunTimeUtil.handleCmds(submitParam.getArgs())) .build(); - Pipeline pipeline = PackagedProgramUtils.getPipelineFromProgram(program, configuration, tEnv.getStreamExecutionEnvironment().getParallelism(), true); + Pipeline pipeline = PackagedProgramUtils.getPipelineFromProgram( + program, configuration, tEnv.getStreamExecutionEnvironment().getParallelism(), true); program.close(); Assert.isTrue(pipeline instanceof StreamGraph, "can not translate"); return (StreamGraph) pipeline;