Skip to content

Commit

Permalink
Spotless Apply
Browse files Browse the repository at this point in the history
  • Loading branch information
zackyoungh authored and github-actions[bot] committed Feb 19, 2024
1 parent 207d4d4 commit 54888c5
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down

0 comments on commit 54888c5

Please sign in to comment.