Hi all! I am new to Flink and I am trying to test it’s capabilities in some POC where I try to create a pipeline with the

postgres-cdc

connector as source to write to Delta Lake via Trino. However, when using the

jdbc

connector to write to Trino I get the following error:

Caused by: java.lang.IllegalStateException: Could not find any jdbc dialect factory that can handle url 'jdbc:<trino://localhost:8080/deltalake>' that implements 'org.apache.flink.connector.jdbc.dialect.JdbcDialectFactory' in the classpath.

What would be the best way to sink the data to Trino? Any suggestions? Thanks!

You can try out this connector to write data to Delta Lake.

Thanks for your reply! I have checked out that connector, but I am not sure if it is capable of writing updates (generated from cdc). Looking at the feature requests that connector is not capable of doing updates.

Native Delta Connector is your best bet. Standard FileSink doesn’t support updates. And Trino’s JDBC support probably only works for reads.