Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
Description
Support to configure the watermark emit strategy for the source which implements the `SupportsWatermarkPushDown` interface.
User could configure the watermark emit strategy in flink sql job with table options or 'OPTIONS' hint,as discussed in https://cwiki.apache.org/confluence/display/FLINK/FLIP-296%3A+Extend+watermark-related+features+for+SQL