[
https://issues.apache.org/jira/browse/KAFKA-14400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637240#comment-17637240
]
Victor van den Hoven edited comment on KAFKA-14400 at 11/23/22 4:09 PM:
------------------------------------------------------------------------
Am I correct that when one +LAST+ input record is written to the left-input
stream not within any window and when no more input records are written to any
of the input streams, then this LAST input record will never be emitted?
The question remains though
In the kstream-kstream-join table of the "Improved Left/Outer Stream-Stream
Join" on the wiki page that was referred to: Why is "d,ts=14" not also joined
with "A,ts=3" as the window size is 15? And why is "D,ts=15" not also joined
with "A,ts=3"?
Thank you for taking the time to explain the new API-semantics to me.
It is all clear to me now. I wasn't aware of the new semantics.
Apologies for the inconvenience
So it is not a bug indeed and the issue can be closed.
was (Author: victorvandenhoven):
Thank you for taking the time to explain the new API-semantics to me.
It is all clear to me now. I wasn't aware of the new semantics.
Apologies for the inconvenience
So it is not a bug indeed and the issue can be closed.
Am I correct that when one +LAST+ input record is written to the left-input
stream not within any window and when no more input records are written to any
of the input streams, then this LAST input record will never be emitted?
The question remains though
In the kstream-kstream-join table of the "Improved Left/Outer Stream-Stream
Join" on the wiki page that was referred to: Why is "d,ts=14" not also joined
with "A,ts=3" as the window size is 15? And why is "D,ts=15" not also joined
with "A,ts=3"?
> KStream - KStream - LeftJoin() does not call ValueJoiner with null value
> -------------------------------------------------------------------------
>
> Key: KAFKA-14400
> URL: https://issues.apache.org/jira/browse/KAFKA-14400
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 3.1.1, 3.3.1
> Environment: Windows PC
> Reporter: Victor van den Hoven
> Priority: Major
> Attachments: Afbeelding 2.png, SimpleStreamTopology.java,
> SimpleStreamTopologyTest.java
>
>
> In Kafka-streams 3.1.1 :
> When using +JoinWindows.ofTimeDifferenceWithNoGrace(Duration.ofMillis(10000))+
> the KStream {*}leftJoin{*}(KStream otherStream, ValueJoiner {_}joiner{_},
> JoinWindows windows) does not seem to call the _joiner_ with null value when
> join predicate is not satisfied (not expected).
>
> When using deprecated +JoinWindows.of(Duration.ofMillis(10000));+
> the KStream {*}leftJoin{*}(KStream otherStream, ValueJoiner {_}joiner{_},
> JoinWindows windows) does
> call the _joiner_ with null value when join predicate is not satisfied (as
> expected and documented).
>
> Attached you can find two files with TopologyTestDriver Unit test to
> reproduce.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
