Flink CDC Issue Import created FLINK-34811: ----------------------------------------------
Summary: [Bug] [sqlserver cdc] the field "snapshot" is always "false" Key: FLINK-34811 URL: https://issues.apache.org/jira/browse/FLINK-34811 Project: Flink Issue Type: Bug Components: Flink CDC Reporter: Flink CDC Issue Import ### Search before asking - [X] I searched in the [issues|https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar. ### Flink version 1.13.6 ### Flink CDC version 2.5-SNAPSHOT ### Database and its version sqlserver 2016 ### Minimal reproduce step execute demo like ` SqlServerSourceBuilder.SqlServerIncrementalSource<String> sqlServerSource = new SqlServerSourceBuilder() .hostname("xxx") .port(1433) .databaseList("xxx") // monitor sqlserver database .tableList("dbo.xxx") // monitor products table .username("xxx") .password("xxx") .deserializer(new JsonDebeziumDeserializationSchema()) // converts SourceRecord to JSON String .startupOptions(StartupOptions.initial()) .build(); DataStream<String> originDataStream = env.fromSource(sqlServerSource,WatermarkStrategy.noWatermarks(),"cdc"); originDataStream.print(); env.execute("Print SqlServer Snapshot + Change Stream"];` ### What did you expect to see? I can distinguish whether the data printed is snapshot or incremental by the 'snapshot' field ### What did you see instead? the field "snapshot" is always "false" ### Anything else? _No response_ ### Are you willing to submit a PR? - [ ] I'm willing to submit a PR! ---------------- Imported from GitHub ---------------- Url: https://github.com/apache/flink-cdc/issues/2465 Created by: [edmond-kk|https://github.com/edmond-kk] Labels: bug, Created at: Wed Sep 06 17:31:20 CST 2023 State: open -- This message was sent by Atlassian Jira (v8.20.10#820010)