Hello Sachin,
Thanks for the detailed description.
Your find is right that for stream-table join the table-side updates would
not trigger a join since stream records are not "materialized" or buffered
during the processing. The community has requested similar semantics to
improve as table-table j
I figured out the issue.
Basically my table2Mapped which is created from stream2 has some messages
that arrive later than they arrive at stream1 for same key.
After checking stream to table semantics I found that the left side is
joined to right side only for the record that exist for that key tha
Hi,
I am facing some weird problems when joining two streams or a stream/table.
The joined stream does not contain all the joined records.
Also note that my keys are custom keys for which I have implemented equals
and hashcode method
Is there something else also I need to do to ensure key1 === key