flink-cdc
flink-cdc copied to clipboard
when will flink cdc mysql 2.X support specific-offset
[ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.api.ValidationException: Unsupported option value 'specific-offset', the options [earliest-offset, specific-offset, timestamp] are not supported correctly, please do not use them until they're correctly supported
Hi @lijunkai ,Pr has opened , pay attention to this pr https://github.com/ververica/flink-cdc-connectors/pull/1157.
PR #1661 fixed this issue.