Skip to content

Commit c93c65e

Browse files
committed
优化代码
1 parent 92324ed commit c93c65e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

dinky-core/src/main/java/org/dinky/job/runner/JobJarRunner.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -179,7 +179,7 @@ private Pipeline getPipeline(JobStatement jobStatement) {
179179
? savePointPath
180180
: configJson.get(SavepointConfigOptions.SAVEPOINT_PATH.key());
181181
JarSubmitParam submitParam = JarSubmitParam.getInfo(jobStatement.getStatement());
182-
boolean allowNonRestored = Boolean.TRUE.equals(submitParam.getAllowNonRestoredState());
182+
boolean allowNonRestored = submitParam.getAllowNonRestoredState();
183183
log.info(
184184
"Setting savepoint restore settings, path: {}, allowNonRestoredState: {}",
185185
effectivePath,

0 commit comments

Comments
 (0)