Hi Andrey,
Regarding the streaming join operator, it handles RowKind differently
based on the type of join:
For inner joins, it directly forwards the input RowKind.
For other types of joins (e.g., left, right, or full outer joins), it
simplifies processing by always emitting INSERT and DELETE mes
Hi, we are also paying attention to this issue and have completed the
validation of the minibatch join optimization including the intermediate
message folding you mentioned. We plan to officially release it in Flink 1.19.
This optimization could significantly improves the performance of join
op
