[APIE-713] - Add support for CP Flink savepoint management

[tmalikconfluent]

Release Notes

Breaking Changes

• PLACEHOLDER

New Features

• Add confluent flink savepoint and confluent flink detached-savepoint commands

Bug Fixes

• PLACEHOLDER

Checklist

• I have successfully built and used a custom CLI binary, without linter issues from this PR.
• I have clearly specified in the What section below whether this PR applies to Confluent Cloud, Confluent Platform, or both.
• I have verified this PR in Confluent Cloud pre-prod or production environment, if applicable.
• I have verified this PR in Confluent Platform on-premises environment, if applicable.
• I have attached manual CLI verification results or screenshots in the Test & Review section below.
• I have added appropriate CLI integration or unit tests for any new or updated commands and functionality.
• I confirm that this PR introduces no breaking changes or backward compatibility issues.
• I have indicated the potential customer impact if something goes wrong in the Blast Radius section below.
• I have put checkmarks below confirming that the feature associated with this PR is enabled in:
  • Confluent Cloud prod
  • Confluent Cloud stag
  • Confluent Platform
  • Check this box if the feature is enabled for certain organizations only

What

CLI for CP Flink savepoint management

Blast Radius

flink application commands could be affected

References

https://confluentinc.atlassian.net/browse/APIE-713

Test & Review

Added extensive integration tests.
Manual testing link: https://docs.google.com/document/d/1IifibpQAUlWNx6zMhSJfL-NMr4VxjbajQxne6vNE8Ao/edit?tab=t.0

[confluent-cla-assistant]

🎉 All Contributor License Agreements have been signed. Ready to merge.
_{Please push an empty commit if you would like to re-run the checks to verify CLA status for all contributors.}

[sgagniere]

Thanks! A few nitpicks:

[Copilot]

Pull request overview

This PR adds comprehensive support for Flink savepoint management in Confluent Platform by introducing new CLI commands for both regular and detached savepoints. The implementation provides full CRUD operations and integrates with the CMF REST API through an updated SDK.

Key Changes:

• Added confluent flink savepoint commands (create, list, describe, delete, detach) for managing savepoints associated with applications and statements
• Added confluent flink detached-savepoint commands (create, list, describe, delete) for managing standalone savepoints
• Updated CMF SDK from v0.0.4 to v0.0.5 and refactored REST client to use specialized API interfaces

Reviewed changes

Copilot reviewed 81 out of 84 changed files in this pull request and generated 9 comments.

Show a summary per file

File	Description
internal/flink/command_savepoint*.go	Implements savepoint CRUD operations with support for both application and statement contexts
internal/flink/command_detached_savepoint*.go	Implements detached savepoint management commands independent of applications/statements
pkg/flink/cmf_rest_client.go	Refactored to use specialized API interfaces and added savepoint-related client methods
test/test-server/flink_onprem_*.go	Added mock handlers and routes for savepoint endpoints to support integration testing
test/flink_onprem_test.go	Added comprehensive integration tests covering all savepoint operations
test/fixtures/output/flink/*	Added golden files for test output validation across different scenarios

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[sgagniere]

Thanks!

I left some comments, but most of them are small / nitpicks.

[sgagniere]

Thanks!

Just a few more comments, mostly about test coverage

[sonarqube-confluent]

Quality Gate passed

Issues
14 New issues
2 Fixed issues
0 Accepted issues

Measures
0 Security Hotspots
83.7% Coverage on New Code
4.7% Duplication on New Code

See analysis details on SonarQube