fix main ci

risingwavelabs · Jan 13, 2025 · 2549e3d · 2549e3d
1 parent c103819
commit 2549e3d
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/integration_tests/elasticsearch-sink/create_sink.sql b/integration_tests/elasticsearch-sink/create_sink.sql
@@ -4,6 +4,7 @@ CREATE SINK bhv_es7_sink
 FROM
     bhv_mv WITH (
     connector = 'elasticsearch',
+    type = 'upsert',
     index = 'test',
     url = 'http://elasticsearch7:9200',
     username = 'elastic',
@@ -14,6 +15,7 @@ CREATE SINK bhv_es8_sink
 FROM
     bhv_mv WITH (
     connector = 'elasticsearch',
+    type = 'upsert',
     index = 'test',
     url = 'http://elasticsearch8:9200',
     username = 'elastic',
@@ -24,6 +26,7 @@ CREATE SINK es7_types_sink
 FROM
     es_types WITH (
     connector = 'elasticsearch',
+    type = 'upsert',
     index = 'test_types',
     primary_key = 'types_id',
     url = 'http://elasticsearch7:9200',
@@ -35,6 +38,7 @@ CREATE SINK es8_types_sink
 FROM
     es_types WITH (
     connector = 'elasticsearch',
+    type = 'upsert',
     index = 'test_types',
     primary_key = 'types_id',
     url = 'http://elasticsearch8:9200',