You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by shimin huang <hu...@gmail.com> on 2020/11/17 02:53:17 UTC

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

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

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

Posted by Jark Wu <im...@gmail.com>.

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

On Tue, 17 Nov 2020 at 10:53, shimin huang <hu...@gmail.com>
wrote:

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