[Bug][Flink]: reverse message order when retract message from message queue.

[baiyangtx]

What happened?

when flink do retract from message queue, it shoud be apply in reverse order. currently flink engine do retract as same order in message queue, this may cause message lost.

Affects Versions

under 0.3.2

What engines are you seeing the problem on?

Flink

How to reproduce

when retract message contained update, the order of message is UPDATE_BEFORE , UPDATE_AFTER.

currently the retract order is UPDATE_BEFORE -> INSERT , UPDATE_AFTER -> DELETE. after retract, this message is lost.

Relevant log output

No response

Anything else

No response

Code of Conduct

• I agree to follow this project's Code of Conduct