Skip to content

Commit 11cde2e

Browse files
committed
Fix lint
1 parent 20a0e7f commit 11cde2e

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/bluegreen/BlueGreenUtils.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -352,10 +352,7 @@ public static FlinkDeployment prepareFlinkDeployment(
352352
spec.getTemplate().getSpec().getJob().getInitialSavepointPath();
353353
if (initialSavepointPath != null && !initialSavepointPath.isEmpty()) {
354354
LOG.info("Using initialSavepointPath: " + initialSavepointPath);
355-
spec.getTemplate()
356-
.getSpec()
357-
.getJob()
358-
.setInitialSavepointPath(initialSavepointPath);
355+
spec.getTemplate().getSpec().getJob().setInitialSavepointPath(initialSavepointPath);
359356
} else {
360357
LOG.info("Clean startup with no checkpoint/savepoint restoration");
361358
}

0 commit comments

Comments
 (0)