THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Discussion thread | https://lists.apache.org/thread/d681bx4t935c30zl750gy6d41tfypbph | ||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
| Vote thread | https://lists.apache.org/thread/79thsvkfpgsqnktodj2901jp538js19j | ||||||||||
| JIRA |
| JIRA
| |||||||||
| Release | -1.18.0 |
Motivation
Now many watermark-related features such as the watermark alignment have been implemented on the datastream API, and it is very convenient and flexible to configure and use these features through the datastream API. However, there is currently no way to use these features through SQL.
...
| Code Block | ||
|---|---|---|
| ||
-- configure in table options CREATE TABLE user_actions ( ... user_action_time TIMESTAMP(3), WATERMARK FOR user_action_time AS user_action_time - INTERVAL '5' SECOND ) WITH ( 'scan.watermark.idle-timeout'='1min', ... ); -- use 'OPTIONS' hint select ... from source_table /*+ OPTIONS('scan.watermark.idle-timeout'='1min') */ |
...
| Code Block | ||
|---|---|---|
| ||
'scan.watermark.emit.strategy'='on-event',
'scan.watermark.idle-timeout'='1min',
'scan.watermark.alignment.group'='alignment-group-1',
'scan.watermark.alignment.max-drift'='1min',
'scan.watermark.alignment.update-interval'='1s' |
...