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
---