[FLINK-10188] Solve nondeterministic functions problem for retraction

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Abandoned
• Component/s: Table SQL / API
• Assignee: Unassigned
• Reporter: Hequn Cheng
• Created: 21/Aug/18 06:51
• Updated: 30/Jan/19 10:41
• Resolved: 30/Jan/19 10:41

Description

Discussion on the mailing list. 

Currently, Retraction has not considered non-deterministic functions. For sql like:

source -> group by -> 
                       non-window join -> retract_sink
source -> group by -> 

The group by will send retract messages to join. However, if we add LOCALTIMESTAMP between group by and join, messages can not be retracted correctly in join, since join retract messages according to the whole row.