mjsax opened a new pull request #10917: URL: https://github.com/apache/kafka/pull/10917
The fix to avoid spurious left/outer stream-stream join results, showed very low throughput for RocksDB, due to excessive creation of iterators. Instead of trying to emit left/outer stream-stream join result for every input record, this PR adds tracking of the lower timestamp bound of left/outer join candidates, and only tries to emit them (and create an iterator) if they are potentially old enough. Call for review @guozhangwang @spena @vcrfxia -- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
