Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5481
Thanks for the review and suggestions. And your comment on
`DataStream#process(KeyedProcessFunction)` makes sense, I've removed it.
(btw, I feel https://github.com/apache/flink/pull/5500 is more urgent that
this PR. Can you take it look at that one?)---
