Skip to content

Commit ddc645b

Browse files
hiliuxghelloliuxg@gmail.com
andauthored
[hotfix][k8s] Fix command-line option from-savepoint does not work in K8s deployment mode
This closes #3825. Co-authored-by: helloliuxg@gmail.com <xiaogenliu@kugou.net>
1 parent 92081df commit ddc645b

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliExecutor.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -74,10 +74,10 @@ public PipelineExecution.ExecutionInfo run() throws Exception {
7474
ComposeDeploymentFactory composeDeploymentFactory = new ComposeDeploymentFactory();
7575
PipelineDeploymentExecutor composeExecutor =
7676
composeDeploymentFactory.getFlinkComposeExecutor(commandLine);
77-
return composeExecutor.deploy(
78-
commandLine,
79-
org.apache.flink.configuration.Configuration.fromMap(flinkConfig.toMap()),
80-
additionalJars);
77+
org.apache.flink.configuration.Configuration configuration =
78+
org.apache.flink.configuration.Configuration.fromMap(flinkConfig.toMap());
79+
SavepointRestoreSettings.toConfiguration(savepointSettings, configuration);
80+
return composeExecutor.deploy(commandLine, configuration, additionalJars);
8181
} else {
8282
// Run CDC Job And Parse pipeline definition file
8383
PipelineDefinitionParser pipelineDefinitionParser = new YamlPipelineDefinitionParser();

0 commit comments

Comments
 (0)