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 <[email protected]>
AuthorDate: Mon Dec 4 17:30:05 2023 +0800
test operate txn 2pc exception handling (#27924)
Co-authored-by: qinhao <[email protected]>
---
.../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: [email protected]
For additional commands, e-mail: [email protected]
