Hello All, I encountered the following error when ...
# troubleshooting
a
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)