This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 4ee9547de61 [fix](regression test)Fix unstable case
es_catalog_http_open_api (#41274) (#41332)
4ee9547de61 is described below
commit 4ee9547de617ad2176da41f2c6124340b2d1cf28
Author: qiye <[email protected]>
AuthorDate: Thu Sep 26 20:49:35 2024 +0800
[fix](regression test)Fix unstable case es_catalog_http_open_api (#41274)
(#41332)
---
.../es/test_es_catalog_http_open_api.groovy | 16 ++++++++++------
1 file changed, 10 insertions(+), 6 deletions(-)
diff --git
a/regression-test/suites/external_table_p0/es/test_es_catalog_http_open_api.groovy
b/regression-test/suites/external_table_p0/es/test_es_catalog_http_open_api.groovy
index 485cdd06186..9eafacacbb1 100644
---
a/regression-test/suites/external_table_p0/es/test_es_catalog_http_open_api.groovy
+++
b/regression-test/suites/external_table_p0/es/test_es_catalog_http_open_api.groovy
@@ -24,9 +24,13 @@ suite("test_es_catalog_http_open_api",
"p0,external,es,external_docker,external_
String es_7_port = context.config.otherConfigs.get("es_7_port")
String es_8_port = context.config.otherConfigs.get("es_8_port")
- // test old create-catalog syntax for compatibility
+ sql """drop catalog if exists test_es_catalog_http_open_api_es5;"""
+ sql """drop catalog if exists test_es_catalog_http_open_api_es6;"""
+ sql """drop catalog if exists test_es_catalog_http_open_api_es7;"""
+ sql """drop catalog if exists test_es_catalog_http_open_api_es8;"""
+
sql """
- create catalog if not exists test_es_query_es5
+ create catalog if not exists test_es_catalog_http_open_api_es5
properties (
"type"="es",
"elasticsearch.hosts"="http://${externalEnvIp}:$es_5_port";,
@@ -35,7 +39,7 @@ suite("test_es_catalog_http_open_api",
"p0,external,es,external_docker,external_
);
"""
sql """
- create catalog if not exists test_es_query_es6
+ create catalog if not exists test_es_catalog_http_open_api_es6
properties (
"type"="es",
"elasticsearch.hosts"="http://${externalEnvIp}:$es_6_port";,
@@ -45,7 +49,7 @@ suite("test_es_catalog_http_open_api",
"p0,external,es,external_docker,external_
"""
// test new create catalog syntax
- sql """create catalog if not exists test_es_query_es7 properties(
+ sql """create catalog if not exists test_es_catalog_http_open_api_es7
properties(
"type"="es",
"hosts"="http://${externalEnvIp}:$es_7_port";,
"nodes_discovery"="false",
@@ -53,7 +57,7 @@ suite("test_es_catalog_http_open_api",
"p0,external,es,external_docker,external_
);
"""
- sql """create catalog if not exists test_es_query_es8 properties(
+ sql """create catalog if not exists test_es_catalog_http_open_api_es8
properties(
"type"="es",
"hosts"="http://${externalEnvIp}:$es_8_port";,
"nodes_discovery"="false",
@@ -64,7 +68,7 @@ suite("test_es_catalog_http_open_api",
"p0,external,es,external_docker,external_
List<String> feHosts = getFrontendIpHttpPort()
// for each catalog 5..8, send a request
for (int i = 5; i <= 8; i++) {
- String catalog = String.format("test_es_query_es%s", i)
+ String catalog =
String.format("test_es_catalog_http_open_api_es%s", i)
def (code, out, err) = curl("GET",
String.format("http://%s/rest/v2/api/es_catalog/get_mapping?catalog=%s&table=test1";,
feHosts[0], catalog))
logger.info("Get mapping response: code=" + code + ", out=" + out
+ ", err=" + err)
assertTrue(code == 0)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
