From 54888c5200683986c7a10d1073e9e2693262d6a2 Mon Sep 17 00:00:00 2001 From: zackyoungh Date: Mon, 19 Feb 2024 10:11:48 +0000 Subject: [PATCH] Spotless Apply --- .../src/main/java/org/dinky/trans/dml/ExecuteJarOperation.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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;