test(connector): add es-sink compatible test (#14522)

risingwavelabs · Jan 20, 2024 · a856a2e · a856a2e
1 parent 7c33962
commit a856a2e
Show file tree

Hide file tree

Showing 3 changed files with 66 additions and 2 deletions.
diff --git a/integration_tests/elasticsearch-sink/create_sink.sql b/integration_tests/elasticsearch-sink/create_sink.sql
@@ -17,3 +17,25 @@ FROM
     username = 'elastic',
     password = 'risingwave'
 );
+
+CREATE SINK es7_types_sink
+FROM
+    es_types WITH (
+    connector = 'elasticsearch',
+    index = 'test_types',
+    primary_key = 'types_id',
+    url = 'http://elasticsearch7:9200',
+    username = 'elastic',
+    password = 'risingwave'
+);
+
+CREATE SINK es8_types_sink
+FROM
+    es_types WITH (
+    connector = 'elasticsearch',
+    index = 'test_types',
+    primary_key = 'types_id',
+    url = 'http://elasticsearch8:9200',
+    username = 'elastic',
+    password = 'risingwave'
+);
diff --git a/integration_tests/elasticsearch-sink/create_source.sql b/integration_tests/elasticsearch-sink/create_source.sql
diff --git a/integration_tests/elasticsearch-sink/sink_check.py b/integration_tests/elasticsearch-sink/sink_check.py
@@ -2,7 +2,7 @@
 import subprocess
 import sys
 
-relations = ['test']
+relations = ['test', 'test_types']
 
 failed_cases = []
 versions = ['7', '8']