Re: 使用flink1.11.1的debezium-changelog目前是否不支持Watermark

[Jark Wu]

是的。 目前还不支持。
1.12 版本会支持。
你定义 watermark 目的是什么呢？做 window 聚合？

On Tue, 17 Nov 2020 at 10:53, shimin huang 
wrote:

> 报错日志:
> ```
> Currently, defining WATERMARK on a changelog source is not supported
> ```
>

使用flink1.11.1的debezium-changelog目前是否不支持Watermark

[shimin huang]

报错日志:
```
Currently, defining WATERMARK on a changelog source is not supported
```