1515// specific language governing permissions and limitations
1616// under the License.
1717
18- suite(" test_non_overlap_seg_heavy_sc" ) {
18+ suite(" test_non_overlap_seg_heavy_sc" , " nonConcurrent " ) {
1919 def tblName = " test_non_overlap_seg_heavy_sc"
2020 sql """
21- DROP TABLE IF EXISTS ${ tblName} _src
22- """
23- sql """
24- CREATE TABLE IF NOT EXISTS ${ tblName} _src
25- (
26- k INT NOT NULL,
27- v1 INT NOT NULL,
28- v2 INT NOT NULL
29- )
30- DUPLICATE KEY(k)
31- DISTRIBUTED BY HASH(k) BUCKETS 5
32- PROPERTIES(
33- "replication_num" = "1",
34- "light_schema_change" = "true",
35- "disable_auto_compaction" = "true"
36- );
21+ DROP TABLE IF EXISTS ${ tblName}
3722 """
3823
3924 sql """
40- DROP TABLE IF EXISTS ${ tblName} _dst
41- """
42- sql """
43- CREATE TABLE IF NOT EXISTS ${ tblName} _dst
25+ CREATE TABLE IF NOT EXISTS ${ tblName}
4426 (
4527 k INT NOT NULL,
4628 v1 INT NOT NULL,
@@ -50,25 +32,29 @@ suite("test_non_overlap_seg_heavy_sc") {
5032 DISTRIBUTED BY HASH(k) BUCKETS 1
5133 PROPERTIES(
5234 "replication_num" = "1",
53- "light_schema_change" = "true",
54- "disable_auto_compaction" = "true"
35+ "light_schema_change" = "true"
5536 );
5637 """
5738
58- sql """ INSERT INTO ${ tblName} _src VALUES (1, 1, 1),(2, 2, 2),(3, 3, 3),(4, 4, 4),(5, 5, 5) """
39+ GetDebugPoint (). clearDebugPointsForAllBEs();
40+ GetDebugPoint (). clearDebugPointsForAllBEs();
41+ GetDebugPoint (). enableDebugPointForAllBEs(" MemTable.need_flush" );
42+ try {
43+ sql """ INSERT INTO ${ tblName} select number, number, number from numbers("number" = "3240960") """
5944
60- sql """ INSERT INTO ${ tblName} _dst SELECT * FROM ${ tblName } _src """
45+ sql """ DELETE FROM ${ tblName} WHERE v2 = 24 """
6146
62- sql """ DELETE FROM ${ tblName} _dst WHERE v1 = 1 """
47+ sql """ ALTER TABLE ${ tblName} DROP COLUMN v2 """
6348
64- sql """ ALTER TABLE ${ tblName} _dst DROP COLUMN v1"""
49+ sql """ ALTER TABLE ${ tblName} MODIFY COLUMN v1 STRING NOT NULL """
6550
66- sql """ ALTER TABLE ${ tblName} _dst MODIFY COLUMN v2 STRING NOT NULL """
51+ waitForSchemaChangeDone {
52+ sql """ SHOW ALTER TABLE COLUMN WHERE TableName='${ tblName} ' ORDER BY createtime DESC LIMIT 1 """
53+ time 600
54+ }
6755
68- waitForSchemaChangeDone {
69- sql """ SHOW ALTER TABLE COLUMN WHERE TableName=' ${ tblName } _dst' ORDER BY createtime DESC LIMIT 1 """
70- time 600
56+ qt_sql """ SELECT count(*) FROM ${ tblName } """
57+ } finally {
58+ GetDebugPoint () . clearDebugPointsForAllBEs();
7159 }
72-
73- qt_sql """ SELECT * FROM ${ tblName} _dst ORDER BY k """
7460}
0 commit comments