1. https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sql/queries.html#deduplication 2. 这是1.12 的功能，定义在 sink DDL with 属性里的。
On Mon, 16 Nov 2020 at 14:18, jindy_liu <[email protected]> wrote: > 哦，这样啊 > 1、加上一个 deduplicate by sink key 节点在sql中是怎么写的？ > 2、另外sql 中有关键字能单独指定一条sink sql的并发度吗？ > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
