Re: Flink CDC to Paimon

2025-03-11 Thread Andrew Otto
In case this helps, here are the versions I was working with when I was experimenting with this last year: https://github.com/ottomata/flink-cdc-spike/blob/main/dockerfiles/build_env_1.17.env https://github.com/ottomata/flink-cdc-spike/blob/main/dockerfiles/download_dependencies.sh I was trying m

Re: Flink CDC to Paimon

2025-03-11 Thread Taher Koitawala
Hi All, I am facing issues finding a class Org.apache.flink.cdc.connectors.shaded.org.apache.kafka.connect.json.JsonConverter I have added 1. Flink-connector-base 1.18.1 Flink-connector-debezium 3.1.0 Flink-cdc-pipeline-connectors-values 3.1.0 Flink-cdc-base 3.1.0 Flink-cdc-pipeline-conn

Re: Flink CDC to Paimon

2025-03-06 Thread Taher Koitawala
Hi Leonard, Yes i did see Xianqian’s reply however i thought my email did not go through as the community is often very active but I did not receive a response until Xianqian’s reply. Thank you Xianqian we are currently trying out the suggestions for altering schema via the catalog. Thank yo

Re: Flink CDC to Paimon

2025-03-04 Thread Andrew Otto
; -- Forwarded message - > From: Taher Koitawala > Date: Tue, 11 Feb 2025 at 11:59 AM > Subject: Flink CDC to Paimon > To: Selvam Ragav , > > > Hi Devs, >As a POC we are trying to create a steaming pipeline from MSSQL cdc > to Paimon: > > To

Fwd: Flink CDC to Paimon

2025-03-04 Thread Taher Koitawala
Hi users, please help me here -- Forwarded message - From: Taher Koitawala Date: Tue, 11 Feb 2025 at 11:59 AM Subject: Flink CDC to Paimon To: Selvam Ragav , Hi Devs, As a POC we are trying to create a steaming pipeline from MSSQL cdc to Paimon: To do this we are doing