Skip to content

Commit

Permalink
[feature](selectdb-cloud) Fix rollup/mv case incorrect (apache#1581)
Browse files Browse the repository at this point in the history
  • Loading branch information
SWJTU-ZhangLei authored Apr 4, 2023
1 parent 498ef38 commit 527361b
Show file tree
Hide file tree
Showing 6 changed files with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ suite ("test_agg_mv_schema_change") {

//add materialized view
def mvName = "mv1"
sql "create materialized view ${mvName} as select user_id, date, city, age, sex, sum(cost) from ${tableName} group by user_id, date, city, age, sex, cost;"
sql "create materialized view ${mvName} as select user_id, date, city, age, sum(cost) from ${tableName} group by user_id, date, city, age, sex;"
int max_try_secs = 600
while (max_try_secs--) {
String result = getMvJobState(tableName)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ suite ("test_agg_rollup_schema_change") {

//add rollup
def rollupName = "rollup_cost"
sql "ALTER TABLE ${tableName} ADD ROLLUP ${rollupName}(`user_id`,`date`,`city`,`age`,`sex`, cost);"
sql "ALTER TABLE ${tableName} ADD ROLLUP ${rollupName}(`user_id`,`date`,`city`,`age`, cost);"
int max_try_time = 600
while(max_try_time--){
String result = getRollupJobState(tableName)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ suite ("test_dup_mv_schema_change") {

//add materialized view
def mvName = "mv1"
sql "create materialized view ${mvName} as select user_id, date, city, age,sex from ${tableName};"
sql "create materialized view ${mvName} as select user_id, date, city, age from ${tableName};"

int max_try_time = 600
while(max_try_time--){
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ suite ("test_dup_rollup_schema_change") {

//add rollup
def rollupName = "rollup_cost"
sql "ALTER TABLE ${tableName} ADD ROLLUP ${rollupName}(`user_id`,`date`,`city`,`age`,`sex`, cost);"
sql "ALTER TABLE ${tableName} ADD ROLLUP ${rollupName}(`user_id`,`date`,`city`,`age`, cost);"
int max_try_time = 600
while(max_try_time--){
String result = getRollupJobState(tableName)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ suite ("test_uniq_mv_schema_change") {

//add materialized view
def mvName = "mv1"
sql "create materialized view ${mvName} as select user_id, date, city, age, sex from ${tableName} group by user_id, date, city, age, sex;"
sql "create materialized view ${mvName} as select user_id, date, city, age from ${tableName} group by user_id, date, city, age;"
int max_try_time = 600
while(max_try_time--){
String result = getMvJobState(tableName)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ suite ("test_uniq_rollup_schema_change") {

//add rollup
def rollupName = "rollup_cost"
sql "ALTER TABLE ${tableName} ADD ROLLUP ${rollupName}(`user_id`,`date`,`city`,`age`,`sex`, cost);"
sql "ALTER TABLE ${tableName} ADD ROLLUP ${rollupName}(`user_id`,`date`,`city`,`sex`,`age`, cost);"
int max_try_time = 600
while(max_try_time--){
String result = getRollupJobState(tableName)
Expand Down

0 comments on commit 527361b

Please sign in to comment.