kaijchen commented on code in PR #44713:
URL: https://github.com/apache/doris/pull/44713#discussion_r1872493801
##########
regression-test/suites/fault_injection_p0/test_load_stream_back_pressure_fault_injection.groovy:
##########
@@ -71,67 +71,34 @@ suite("test_load_stream_back_pressure_fault_injection",
"nonConcurrent") {
try {
GetDebugPoint().enableDebugPointForAllBEs("TabletStream.append_data.long_wait")
- def thread1 = new Thread({
- try {
- def res = sql "insert into test select * from baseall where k1
<= 3"
- logger.info(res.toString())
- } catch(Exception e) {
- logger.info(e.getMessage())
- assertTrue(e.getMessage().contains("Communications link
failure"))
+ def kill_thread = new Thread({
+ sleep(3000)
+ def processList = sql "show processlist"
+ logger.info(processList.toString())
+ processList.each { item ->
+ logger.info(item[1].toString())
+ logger.info(item[11].toString())
+ if (item[11].toString() == "insert into test select * from
baseall where k1 <= 3".toString()){
+ def res = sql "kill ${item[1]}"
+ logger.info(res.toString())
+ }
}
})
- thread1.start()
-
- sleep(1000)
-
- def processList = sql "show processlist"
- logger.info(processList.toString())
- processList.each { item ->
- logger.info(item[1].toString())
- logger.info(item[11].toString())
- if (item[11].toString() == "insert into test select * from baseall
where k1 <= 3".toString()){
- def res = sql "kill ${item[1]}"
- logger.info(res.toString())
- }
+ kill_thread.start()
+ try {
+ def res = sql "insert into test select * from baseall where k1 <=
3"
+ logger.info(res.toString())
+ assertTrue(false, "Expected exception to be thrown")
+ } catch(Exception e) {
+ logger.info(e.getMessage())
+ assertTrue(e.getMessage().contains("wait flush token back pressure
time is more than load_stream_max_wait_flush_token_time"))
+ //assertTrue(e.getMessage().contains("Communications link
failure"))
Review Comment:
the previous error message seems incorrect
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
