从同一个source里select，在flink sql中用statement set 执行两条insert语句到不同的sink表即可
Jiabao Sun 于2023年12月29日周五 16:55写道：
> Hi,
>
> 使用 SQL 的话不太好实现写入多个路径，
> 使用 DataStream 的话可以考虑自己实现一个 RichSinkFunction。
>
> Best,
> Jiabao
>
> On 2023/12/29 08:37:34 jinzhuguang wrote:
> > Flink版本：1.16.0
> >
> > 看官网上的案例：
> > CREATE
Hi,
使用 SQL 的话不太好实现写入多个路径，
使用 DataStream 的话可以考虑自己实现一个 RichSinkFunction。
Best,
Jiabao
On 2023/12/29 08:37:34 jinzhuguang wrote:
> Flink版本：1.16.0
>
> 看官网上的案例：
> CREATE TABLE MyUserTable (
> column_name1 INT,
> column_name2 STRING,
> ...
> part_name1 INT,
> part_name2 STRING
> )
Flink版本：1.16.0
看官网上的案例：
CREATE TABLE MyUserTable (
column_name1 INT,
column_name2 STRING,
...
part_name1 INT,
part_name2 STRING
) PARTITIONED BY (part_name1, part_name2) WITH (
'connector' = 'filesystem', -- 必选：指定连接器类型
'path' = 'file:///path/to/whatever', -- 必选：指定路径
