gustavodemorais commented on PR #29204: URL: https://github.com/apache/flink/pull/29204#issuecomment-5818622671
Hey @MartijnVisser and everyone, I agree that this is a bug. The output is incorrect. I took a brief look at what else might be broken and what works: **Also broken** - Non-equi joins (e.g. `a.k = b.k AND a.v > b.v`): an update that stops the match leaves a stale joined row. No DELETE needed, and fixing the counter doesn't cover it. MultiJoin is affected too. - Restored state keeps its inflated counters, even after a fix. Worth adding a restore test. Only new statements or new keys will work correctly. **Works** - MultiJoin: some good news, MJ works for the examples in the PR. - Updates on the preserved side (the left side of a LEFT JOIN). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
