Flink版本

flink1.12开始支持primary key。

因为flink引擎不会存储所有数据，所以只支持NOT ENFORCED 模式。

DDL任务

CREATE TABLE MyTable (
  MyField1 INT,
  MyField2 STRING,
  MyField3 BOOLEAN,
  PRIMARY KEY (MyField1, MyField2) NOT ENFORCED  -- defines a primary key on columns
) WITH (
  ...
)

Metahub任务

set 'four_col_with_comb_pks.primary.keys' = 'col1,col2';-- four_col_with_comb_pks是表名，多个字段用逗号隔开