You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:37:00 UTC
[jira] [Updated] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions
[ https://issues.apache.org/jira/browse/FLINK-35693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yanquan Lv updated FLINK-35693:
-------------------------------
Fix Version/s: (was: cdc-3.5.0)
> 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
> Priority: Major
>
> 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)