[ https://issues.apache.org/jira/browse/FLINK-35255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
yanghuai updated FLINK-35255: ----------------------------- Summary: DataSinkWriterOperator should override snapshotState and processWatermark method (was: DataSinkWriterOperator should override snapshotState和processWatermark method) > DataSinkWriterOperator should override snapshotState and processWatermark > method > -------------------------------------------------------------------------------- > > Key: FLINK-35255 > URL: https://issues.apache.org/jira/browse/FLINK-35255 > Project: Flink > Issue Type: Bug > Components: Flink CDC > Reporter: yanghuai > Priority: Blocker > > DataSinkWriterOperator just override > org.apache.flink.streaming.api.operators.AbstractStreamOperator#initializeState,but > not override > org.apache.flink.streaming.api.operators.AbstractStreamOperator#snapshotState > and > org.apache.flink.streaming.api.operators.AbstractStreamOperator#processWatermark. > -- This message was sent by Atlassian Jira (v8.20.10#820010)