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

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

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

shimin huang
报错日志:
```
Currently, defining WATERMARK on a changelog source is not supported
```
Reply | Threaded
Open this post in threaded view
|

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

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

On Tue, 17 Nov 2020 at 10:53, shimin huang <[hidden email]>
wrote:

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