flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hequn Cheng (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-10188) Solve nondeterministic functions problem for retraction
Date Tue, 21 Aug 2018 06:53:00 GMT

     [ https://issues.apache.org/jira/browse/FLINK-10188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Hequn Cheng updated FLINK-10188:
--------------------------------
    Description: 
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.

  was:
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.


> 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
>            Priority: Major
>
> 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)

Mime
View raw message