Hi. cloud young. The property 'log.mining.strategy' is actually a setting from the oracle debezium connector[1]. Are some exceptions able to be found in your job and which version are you using?
Best, Hang [1] https://debezium.io/documentation/reference/1.9/connectors/oracle.html#oracle-property-log-mining-strategy cloud young <aoyunyo...@gmail.com> 于2024年5月8日周三 16:35写道： > I have read the doc ncremental-snapshot-based-datastream-experimental > <https://nightlies.apache.org/flink/flink-cdc-docs-release-3.0/docs/connectors/legacy-flink-cdc-sources/oracle-cdc/#incremental-snapshot-based-datastream-experimental> > , > and run the example code. It works. but I also need to get the ddl changes, > so I change the debeziumProperties.setProperty("log.mining.strategy", > "online_catalog"); > to debeziumProperties.setProperty("log.mining.strategy", > "redo_log_catalog"); > after I run the modified code, there is nothing print in the console. > I set a breakpoint at JsonDebeziumDeserializationSchema#deserialize > method, the method not invoked at all. > why? how to resolve this? >
