Github user xccui commented on the issue:
https://github.com/apache/flink/pull/5140
Hi @fhueske, thanks for your concrete suggestions! IMO, the refactorings in
`TimeBoundedStreamJoin` are quite reasonable, while the refactoring for
`createNegativeWindowSizeJoin()` may not be so significant as the negative
window size should be taken as an exception. Anyway, I've applied them for
better efficiency. ð
Thanks, Xingcan---
