lincoln lee created FLINK-29225: ----------------------------------- Summary: Delete message incorrectly ignored in SinkUpsertMaterializer Key: FLINK-29225 URL: https://issues.apache.org/jira/browse/FLINK-29225 Project: Flink Issue Type: Bug Affects Versions: 1.15.2, 1.14.5 Reporter: lincoln lee Fix For: 1.16.0, 1.14.6, 1.15.3
Currently if the interval between the arrival of the delete message and the insert/update message exceeds state ttl, the delete message was ignored incorrectly in `SinkUpsertMaterializer`. This will cause wrong result in corresponding sink table(dirty data left). -- This message was sent by Atlassian Jira (v8.20.10#820010)