If we have two streams A and B for which we associate tables tA and tB,
then create a table tC as ta.leftJoin(tB, <some value joiner>) and then we
have a key kB in stream B but never made it to tA nor tC, do we need to
inject a pair (k,v) of (kB, null) into resulting change log for tC ?

It sounds like it is definitely necessary if key kB is present in table tC
but if not, why add it?

I have an example that reproduces this and would like to know if it is
considered normal, sub-optimal, or a defect. I don't view it as normal for
time being, particularly considering stream A as having very few keys and B
as having many, which could lead to an unnecessary large change log for C.

Phil

Reply via email to