This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new d5ff765e5bd [regression-test](point query) make test stable (#31140)
d5ff765e5bd is described below
commit d5ff765e5bd751a79aae1e5feda9c4a7ec72a253
Author: lihangyu <[email protected]>
AuthorDate: Wed Feb 21 10:22:39 2024 +0800
[regression-test](point query) make test stable (#31140)
---
.../suites/point_query_p0/test_point_query.groovy | 18 ++++++++++--------
.../test_point_query_cluster_key.groovy | 19 ++++++++++---------
2 files changed, 20 insertions(+), 17 deletions(-)
diff --git a/regression-test/suites/point_query_p0/test_point_query.groovy
b/regression-test/suites/point_query_p0/test_point_query.groovy
index e919bb7a026..f7df5ab820f 100644
--- a/regression-test/suites/point_query_p0/test_point_query.groovy
+++ b/regression-test/suites/point_query_p0/test_point_query.groovy
@@ -18,15 +18,14 @@
import java.math.BigDecimal;
suite("test_point_query") {
+ def backendId_to_backendIP = [:]
+ def backendId_to_backendHttpPort = [:]
+ getBackendIpHttpPort(backendId_to_backendIP, backendId_to_backendHttpPort);
def set_be_config = { key, value ->
- String backend_id;
- def backendId_to_backendIP = [:]
- def backendId_to_backendHttpPort = [:]
- getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
-
- backend_id = backendId_to_backendIP.keySet()[0]
- def (code, out, err) =
update_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), key, value)
- logger.info("update config: code=" + code + ", out=" + out + ", err="
+ err)
+ for (String backend_id: backendId_to_backendIP.keySet()) {
+ def (code, out, err) =
update_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), key, value)
+ logger.info("update config: code=" + code + ", out=" + out + ",
err=" + err)
+ }
}
try {
set_be_config.call("disable_storage_row_cache", "false")
@@ -65,6 +64,8 @@ suite("test_point_query") {
def nprep_sql = { sql_str ->
def url_without_prep = "jdbc:mysql://" + sql_ip + ":" + sql_port +
"/" + realDb
connect(user = user, password = password, url = url_without_prep) {
+ // set to false to invalid cache correcly
+ sql "set enable_memtable_on_sink_node = false"
sql sql_str
}
}
@@ -198,6 +199,7 @@ suite("test_point_query") {
qe_point_select stmt
qe_point_select stmt
// invalidate cache
+ sql "sync"
nprep_sql """ INSERT INTO ${tableName} VALUES(1235,
120939.11130, "a ddd", "xxxxxx", "2030-01-02", "2020-01-01 12:36:38",
22.822, "7022-01-01 11:30:38", 0, 1929111.1111,[119291.19291], ["111", "222",
"333"], 2) """
qe_point_select stmt
qe_point_select stmt
diff --git
a/regression-test/suites/point_query_p0/test_point_query_cluster_key.groovy
b/regression-test/suites/point_query_p0/test_point_query_cluster_key.groovy
index 700f19b53d1..a117199297d 100644
--- a/regression-test/suites/point_query_p0/test_point_query_cluster_key.groovy
+++ b/regression-test/suites/point_query_p0/test_point_query_cluster_key.groovy
@@ -18,16 +18,15 @@
import java.math.BigDecimal;
suite("test_point_query_cluster_key") {
+ def backendId_to_backendIP = [:]
+ def backendId_to_backendHttpPort = [:]
+ getBackendIpHttpPort(backendId_to_backendIP, backendId_to_backendHttpPort);
def set_be_config = { key, value ->
- String backend_id;
- def backendId_to_backendIP = [:]
- def backendId_to_backendHttpPort = [:]
- getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
-
- backend_id = backendId_to_backendIP.keySet()[0]
- def (code, out, err) =
update_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), key, value)
- logger.info("update config: code=" + code + ", out=" + out + ", err="
+ err)
- }
+ for (String backend_id: backendId_to_backendIP.keySet()) {
+ def (code, out, err) =
update_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), key, value)
+ logger.info("update config: code=" + code + ", out=" + out + ",
err=" + err)
+ }
+ }
try {
set_be_config.call("disable_storage_row_cache", "false")
// nereids do not support point query now
@@ -65,6 +64,8 @@ suite("test_point_query_cluster_key") {
def nprep_sql = { sql_str ->
def url_without_prep = "jdbc:mysql://" + sql_ip + ":" + sql_port +
"/" + realDb
connect(user = user, password = password, url = url_without_prep) {
+ // set to false to invalid cache correcly
+ sql "set enable_memtable_on_sink_node = false"
sql sql_str
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
