Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/4183
BTW. The PR adjust the watermark by injecting a custom operator, that can
ensure the integrity of the data. It is currently reasonable, but in essence
the watermark adjustment should be carried out on the data source, that is we
should config the watermark in definition of table. In the future FLINK need to
support the DDL, we should define the watermark strategy when the define DDL.
Therefore we need a whole consideration, that is we do the first temporary
support in the PR or consider the desgin of support DDL. (just like We do the
FLINK-5921 before FLINK-5884), What do you think?
---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
