FlinkFLink SQL TableException: Table sink doesn‘t support consuming update changes which is

Posted 2021-11-02 九师兄

文章目录

• 1.概述
• 2.原因
• 3.解决方案

1.概述

在做实验：【Flink】Flink SQL 读取 CSV 文件 最后尝试将数据写入到csv文件的时候报错。

Flink SQL> INSERT INTO employee_information_sink
> SELECT
>    dept_id,
>    COUNT