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


---

Reply via email to