You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by da...@apache.org on 2023/12/04 09:30:13 UTC
(doris) branch master updated: test operate txn 2pc exception handling (#27924)
This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 283e1ea0b78 test operate txn 2pc exception handling (#27924)
283e1ea0b78 is described below
commit 283e1ea0b78749829aa2a2f0588a4bb212027490
Author: HowardQin <ha...@esgyn.cn>
AuthorDate: Mon Dec 4 17:30:05 2023 +0800
test operate txn 2pc exception handling (#27924)
Co-authored-by: qinhao <qi...@newland.com.cn>
---
.../load_p0/stream_load/test_stream_load_properties.groovy | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy b/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
index 073d464c544..4ba541d3234 100644
--- a/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
+++ b/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
@@ -544,7 +544,7 @@ suite("test_stream_load_properties", "p0") {
String txnId
def tableName1 = "stream_load_" + tableName
- // Invalid txn_id 1
+ // Invalid txn_id string with letters
streamLoad {
table tableName1
set 'column_separator', '|'
@@ -572,7 +572,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals("internal_error", parseJson(body).status.toLowerCase())
assertTrue(parseJson(body).msg.toLowerCase().contains("stoull"))
- // Invalid txn_id 2
+ // Invalid txn_id string with digits and letters
streamLoad {
table tableName1
set 'column_separator', '|'
@@ -725,6 +725,11 @@ suite("test_stream_load_properties", "p0") {
} else {
qt_sql_2pc_commit "select * from ${tableName1} order by k00"
}
+
+ // Commit the same txnId again to trigger operate_txn_2pc() failure
+ body = do_streamload_2pc.call(txnId, "commit", tableName1)
+ assertEquals("analysis_error", parseJson(body).status.toLowerCase())
+ assertTrue(parseJson(body).msg.toLowerCase().contains("is already visible"))
i++
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org