[FLINK-26881] Stop with savepoint should pick up the targetDirectory from Flink configuration

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: kubernetes-operator-0.1.0
• Component/s: Kubernetes Operator
• Labels: pull-request-available
• Assignee: Yang Wang
• Reporter: Yang Wang
• Created: 28/Mar/22 07:41
• Updated: 29/Mar/22 06:25
• Resolved: 28/Mar/22 11:30

Description

Upgrading stateless FlinkDeployment to savepoint still could not work. Because FlinkService#cancelJob does not pick up the target directory in the flink configuration.

 

case SAVEPOINT:
    String savepoint =
            clusterClient
                    .stopWithSavepoint(jobID, false, null)
                    .get(1, TimeUnit.MINUTES); 

We should use configured savepoint directory instead of null in the above implementation.

Issue Links

• links to: GitHub Pull Request #120