更新时间:2022-02-22 GMT+08:00
如何在一个Flink作业中将数据写入到不同的Elasticsearch集群中?
在对应的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;
父主题: 性能调优