This is an automated email from the ASF dual-hosted git repository.
yuxiqian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 201aef601 [FLINK-39407][cdcup] Mount shared data volume on Flink
containers for Paimon sink (#4408)
201aef601 is described below
commit 201aef6015d8494263b94188396d120dc01bb641
Author: Jubin Soni <[email protected]>
AuthorDate: Sat May 23 00:22:33 2026 -0400
[FLINK-39407][cdcup] Mount shared data volume on Flink containers for
Paimon sink (#4408)
* [FLINK-39407][cdcup] Mount shared data volume on Flink containers for
Paimon sink
* [FLINK-39407][cdcup] Scope /data mount to Paimon sink generator
Move the cdc-data:/data volume mount from the generic Flink jobmanager and
taskmanager service definitions in app.rb into
Paimon.prepend_to_docker_compose_yaml, so the mount is only added when the user
selects Paimon as the sink.
---
tools/cdcup/src/sink/paimon.rb | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
diff --git a/tools/cdcup/src/sink/paimon.rb b/tools/cdcup/src/sink/paimon.rb
index 1261bb50d..e418e059f 100644
--- a/tools/cdcup/src/sink/paimon.rb
+++ b/tools/cdcup/src/sink/paimon.rb
@@ -22,8 +22,14 @@ class Paimon
'flink-cdc-pipeline-connector-paimon'
end
- # Nothing to do
- def prepend_to_docker_compose_yaml(_); end
+ # Paimon's FileSystemCatalog writes happen inside the Flink JobManager and
+ # TaskManager, so they need /data backed by the shared cdc-data volume.
+ def prepend_to_docker_compose_yaml(docker_compose_yaml)
+ %w[jobmanager taskmanager].each do |service|
+ docker_compose_yaml['services'][service]['volumes'] ||= []
+ docker_compose_yaml['services'][service]['volumes'] <<
"#{CDC_DATA_VOLUME}:/data"
+ end
+ end
def prepend_to_pipeline_yaml(pipeline_yaml)
pipeline_yaml['sink'] = {
