Hequn Cheng created FLINK-10188:
-----------------------------------
Summary: Solve nondeterministic functions problem for retraction
Key: FLINK-10188
URL: https://issues.apache.org/jira/browse/FLINK-10188
Project: Flink
Issue Type: Bug
Components: Table API & SQL
Reporter: Hequn Cheng
Currently, Retraction has not considered non-deterministic functions. For sql
like:
{code}
source -> group by ->
non-window join -> retract_sink
source -> group by ->
{code}
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
