Help Center/ Data Lake Insight/ FAQs/ Flink Jobs/ Performance Tuning/ How Do I Write Data to Different Elasticsearch Clusters in a Flink Job?
Updated on 2022-09-20 GMT+08:00
View PDF

How Do I Write Data to Different Elasticsearch Clusters in a Flink Job?

Add the following SQL statements to the Flink job:

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;
Parent topic: Performance Tuning