Hongshun Wang created FLINK-35693:
-------------------------------------
Summary: Change variable specificOffsetFile, specificOffsetPos and
startupTimestampMillis to Offset in StartupOptions
Key: FLINK-35693
URL: https://issues.apache.org/jira/browse/FLINK-35693
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cdc-3.1.1
Reporter: Hongshun Wang
Fix For: cdc-3.2.0
Current, StartupOptions use specificOffsetFile, specificOffsetPos and
startupTimestampMillis to describe specific offset or timestamp. However, it's
suitable for mysql, rather than postgres's LSN or oracle's RedoLogOffset.
{code:java}
public final class StartupOptions implements Serializable {
private static final long serialVersionUID = 1L;
public final StartupMode startupMode;
public final String specificOffsetFile;
public final Integer specificOffsetPos;
public final Long startupTimestampMillis;
} {code}
Now that we have already retract Offset to represent the position of log, why
not use offset in StartupOptions?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
