yanghuai created FLINK-35255: -------------------------------- Summary: DataSinkWriterOperator should override snapshotState和processWatermark method Key: FLINK-35255 URL: https://issues.apache.org/jira/browse/FLINK-35255 Project: Flink Issue Type: Bug Components: Flink CDC Reporter: yanghuai Fix For: cdc-3.1.0
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)