Copilot commented on code in PR #66142:
URL: https://github.com/apache/doris/pull/66142#discussion_r3662298844


##########
regression-test/suites/cloud_p0/query_retry/test_retry_e-230.groovy:
##########
@@ -162,7 +162,62 @@ suite("test_retry_e-230", 'docker') {
                 // fe StmtExecutor retry time, at most 25 * 1.5s + 25 * 2.5s
                 assertTrue(cost > 4000 && cost < 100000)
 
+                def restoreTbl = 'test_retry_e_230_restore_tbl'
+                sql """ DROP TABLE IF EXISTS ${restoreTbl} """
+                sql """
+                    CREATE TABLE ${restoreTbl} (
+                    `k1` int(11) NULL,
+                    `k2` int(11) NULL
+                    )
+                    DUPLICATE KEY(`k1`, `k2`)
+                    COMMENT 'OLAP'
+                    DISTRIBUTED BY HASH(`k1`) BUCKETS 1
+                    PROPERTIES (
+                    "replication_num"="1"
+                    );
+                    """
+                for (def i = 1; i <= 3; i++) {
+                    insert_sql """INSERT INTO ${restoreTbl} VALUES (${i}, 
${100 * i})""", 1
+                }
+
+                sql """ set cloud_partition_version_cache_ttl_ms = 3600000 """
+                sql """ set cloud_table_version_cache_ttl_ms = 3600000 """
+                def row_cnt = sql """select count() from ${restoreTbl}"""
+                assertEquals(row_cnt[0][0], 3)
+
+                cluster.injectDebugPoints(NodeType.BE, 
['CloudTablet.capture_rs_readers.return.e-230' : null])
+                cluster.injectDebugPoints(NodeType.FE, 
['StmtExecutor.retry.longtime' : null])
+                insert_sql """INSERT INTO ${restoreTbl} VALUES (4, 400)""", 1
+
+                def futrue5 = thread {
+                    Thread.sleep(4000)
+                    cluster.clearBackendDebugPoints()
+                }
+
+                begin = System.currentTimeMillis();
+                def futrue6 = thread {
+                    def result = sql """select * from ${restoreTbl} order by 
k1"""
+                    log.info("select result: {}", result)
+                }
+
+                futrue6.get()
+                cost = System.currentTimeMillis() - begin;
+                log.info("time cost restore check : {}", cost)
+                futrue5.get()

Review Comment:
   Typo in variable names: `futrue5`/`futrue6` are likely meant to be 
`future5`/`future6`, which improves readability and avoids propagating 
misspellings.



-- 
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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to