DDL中定义的新水印生成策略

Question

在https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/streaming/time_attributes.html中

事件时间属性和水印的DDL为：

CREATE TABLE user_actions (
  user_name STRING,
  data STRING,
  user_action_time TIMESTAMP(3),
  -- declare user_action_time as event time attribute and use 5 seconds delayed watermark strategy
  WATERMARK FOR user_action_time AS user_action_time - INTERVAL '5' SECOND
) WITH (
  ...
);

我想问一问新水印产生的政策：

对于数据流，flink提供了以下两种水印生成策略，在ddl中呢？

像periodically

• punctuated那样周期性地生成

1. ，也就是说，尝试像AssignerWithPunctuatedWatermarks那样生成新的水印，也就是说，在新事件出现时尝试生成新的水印。

Answer 1

水印被周期性地分配。您可以通过配置pipeline.auto-watermark-interval指定间隔。

还请注意，在DataStream API中修改了用于水印的，您提到的两个类现在已经不再推荐了。

1