数据湖探索 DLI-如何在一个Flink作业中将数据写入到不同的Elasticsearch集群中？

时间：2024-12-11 08:41:41

数据湖探索 DLI

如何在一个Flink作业中将数据写入到不同的Elasticsearch集群中？

在Flink 作业中，你可以使用CREATE语句来定义Source表和Sink表，并指定它们的连接器类型以及相关的属性。

如果需要将数据写入到不同的Elasticsearch集群，您需要为每个集群配置不同的连接参数，并确保Flink作业能够正确地将数据路由到各个集群。

例如本例中分别对es1和es2定义连接器类型以及相关的属性。

在对应的Flink作业中添加如下SQL语句。

create source stream ssource(xx);
create sink stream es1(xx) with (xx);
create sink stream es2(xx) with (xx);
insert into es1 select * from ssource;
insert into es2 select * from ssource;

父主题： Flink SQL作业类

上一篇：数据湖探索 DLI-Flink作业重启后，如何判断是否可以从checkpoint恢复:应用场景

下一篇：数据湖探索 DLI-作业语义检验时提示DIS通道不存在怎么处理？

新客秒杀 2核2G 3M L实例

68元/年

普惠上云领千元上云礼券

立即前往

企业专享 X实例 4核8G 5M