You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/08/21 06:52:00 UTC

[jira] [Created] (FLINK-10188) Solve nondeterministic functions problem for retraction

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 &amp; 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)