@@ -68,19 +68,19 @@ suite("test_routine_load_adaptive_param","nonConcurrent") {
6868 def injection = " RoutineLoadTaskInfo.judgeEof"
6969 try {
7070 GetDebugPoint (). enableDebugPointForAllFEs(injection)
71+
7172 RoutineLoadTestUtils . sendTestDataToKafka(producer, kafkaCsvTpoics)
7273 RoutineLoadTestUtils . waitForTaskFinish(runSql, job, tableName, 0 )
74+
75+ logger. info(" ---test adaptively increase---" )
76+ RoutineLoadTestUtils . sendTestDataToKafka(producer, kafkaCsvTpoics)
77+ RoutineLoadTestUtils . checkTaskTimeout(runSql, job, " 3600" )
78+ RoutineLoadTestUtils . checkTxnTimeoutMatchesTaskTimeout(runSql, job, " 3600000" )
79+ RoutineLoadTestUtils . waitForTaskFinish(runSql, job, tableName, 2 )
7380 } finally {
7481 GetDebugPoint (). disableDebugPointForAllFEs(injection)
7582 }
76- // test adaptively increase
77- logger. info(" ---test adaptively increase---" )
78- RoutineLoadTestUtils . sendTestDataToKafka(producer, kafkaCsvTpoics)
79- RoutineLoadTestUtils . checkTaskTimeout(runSql, job, " 3600" )
80- RoutineLoadTestUtils . checkTxnTimeoutMatchesTaskTimeout(runSql, job, " 3600000" )
81- RoutineLoadTestUtils . waitForTaskFinish(runSql, job, tableName, 2 )
8283
83- // test restore adaptively
8484 logger. info(" ---test restore adaptively---" )
8585 RoutineLoadTestUtils . sendTestDataToKafka(producer, kafkaCsvTpoics)
8686 RoutineLoadTestUtils . waitForTaskFinish(runSql, job, tableName, 4 )
0 commit comments