You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2021/08/25 17:06:00 UTC

[jira] [Commented] (KAFKA-10847) Avoid spurious left/outer join results in stream-stream join

    [ https://issues.apache.org/jira/browse/KAFKA-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404607#comment-17404607 ] 

Matthias J. Sax commented on KAFKA-10847:
-----------------------------------------

Updated fixed version to 3.1.0 because of https://issues.apache.org/jira/browse/KAFKA-13216 

> Avoid spurious left/outer join results in stream-stream join 
> -------------------------------------------------------------
>
>                 Key: KAFKA-10847
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10847
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>            Reporter: Matthias J. Sax
>            Assignee: Sergio Peña
>            Priority: Major
>             Fix For: 3.1.0
>
>
> KafkaStreams follows an eager execution model, ie, it never buffers input records but processes them right away. For left/outer stream-stream join, this implies that left/outer join result might be emitted before the window end (or window close) time is reached. Thus, a record what will be an inner-join result, might produce a eager (and spurious) left/outer join result.
> We should change the implementation of the join, to not emit eager left/outer join result, but instead delay the emission of such result after the window grace period passed.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)