Github user hongyuhong commented on the issue:
https://github.com/apache/flink/pull/3715
Hi @fhueske , i have update a version :).
1. As for how to specify the join case is a stream and stream join,
currently i check through there exist time indicator but not exist such as
tumble(proctime).
2. I have test the analyzeTimeBoundary function in JoinTest, for the case
''a.proctime - b.proctime > 5 sec', it will report an error 'Cannot apply '-'
to arguments of type '<TIMESTAMP(3)> - <TIMESTAMP(3)>'. Supported form(s):
'<NUMERIC> - <NUMERIC>''. So maybe we don't need to support such situation.
Another situation is 'timestampdiff(second, a.proctime, b.proctime) > 5', i
seems not yet support in flink, should we add the support?
Thanks very much.
Yuhong
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
