Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4625
Hi @xccui, I think aside from the equi join predicate limitation, all
issues have been addressed. This can be fixed in a follow up task, IMO.
I'll have a last look at the PR and hopefully merge it.
Thanks for the great work,
Fabian
Follow ups will be (some might already have JIRAs):
- enabling streaming joins for the Table API
- blocking of state entries and clean-up improvements
- support for windowed non-equi joins
- support for windowed outer joins
---