Flink利用catalog往mysql表里写数据时，怎么处理自增主建问题呢？

您好！Flink 利用 catalog 往 mysql 表里写数据时，可以通过以下两种方式解决自增主键问题：

1. 使用行号函数 ROW_NUMBER()：sql Copy SELECT ROW_NUMBER () OVER (PARTITION BY col1 ORDER BY col2) AS id, col1, col2 FROM table;
2. 使用内置 proudced 函数 CURRENT_TIMESTAMP()：sql Copy SELECT CAST (CURRENT_TIMESTAMP () AS BIGINT) AS id, col1, col2 FROM table;

这两种方式的值都可以作为自增 ID。