Hello All,
I encountered the following error when trying to write SQL Server CDC data to a local Ubuntu folder in Delta format using Delta Sink. I am using Flink version 1.17.1. For CDC, I'm using com.ververica/flink-sql-connector-sqlserver-cdc/2.4.0. Here's the error message I'm receiving. I would greatly appreciate any assistance or guidance in resolving this issue. Thank you for your help.
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Table sink 'anonymous_datastream_sink$1' doesn't support consuming update and delete changes which is produced by node TableSourceScan(table=[[default_catalog, default_database, CDC_SOURCE_TABLE]], fields=[ID, FirstName])
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105)
at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:851)
at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:245)
at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1095)
at org.apache.flink.client.cli.CliFrontend.lambda$mainInternal$9(CliFrontend.java:1189)
at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
at org.apache.flink.client.cli.CliFrontend.mainInternal(CliFrontend.java:1189)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1157)