Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[fix](p2) fix the failed of cold_heat_separation_p2 #48199

Open
wants to merge 2 commits into
base: master
Choose a base branch
from
Open

[fix](p2) fix the failed of cold_heat_separation_p2 #48199

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
95bb92b
[fix](p2) fix the failed of cold_heat_separation_p2
yagagagaga Feb 22, 2025
3b0569d
fix
yagagagaga Feb 22, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 8 additions & 8 deletions regression-test/suites/cold_heat_separation_p2/add_drop_partition.groovy
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,9 +33,9 @@ suite("add_drop_partition") {
}
}
// data_sizes is one arrayList<Long>, t is tablet
def fetchDataSize = { data_sizes, t ->
def tabletId = t[0]
String meta_url = t[17]
def fetchDataSize = {List<Long> data_sizes, Map<String, Object> t ->
def tabletId = t.TabletId
String meta_url = t.MetaUrl
def clos = { respCode, body ->
logger.info("test ttl expired resp Code {}", "${respCode}".toString())
assertEquals("${respCode}".toString(), "200")
Expand Down Expand Up @@ -136,7 +136,7 @@ suite("add_drop_partition") {
"""

// show tablets from table, 获取第一个tablet的 LocalDataSize1
def tablets = sql """
def tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
log.info( "test tablets not empty")
Expand All @@ -154,15 +154,15 @@ suite("add_drop_partition") {
sleep(600000)


tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
log.info( "test tablets not empty")
fetchDataSize(sizes, tablets[0])
while (sizes[1] == 0) {
log.info( "test remote size is zero, sleep 10s")
sleep(10000)
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
fetchDataSize(sizes, tablets[0])
Expand All @@ -174,7 +174,7 @@ suite("add_drop_partition") {
while (RemoteDataSize1 != originLocalDataSize1 && sleepTimes < 60) {
log.info( "test remote size is same with origin size, sleep 10s")
sleep(10000)
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
fetchDataSize(sizes, tablets[0])
Expand Down Expand Up @@ -285,4 +285,4 @@ suite("add_drop_partition") {



}
}
14 changes: 7 additions & 7 deletions regression-test/suites/cold_heat_separation_p2/add_drop_partition_by_hdfs.groovy
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,9 +33,9 @@ suite("add_drop_partition_by_hdfs") {
}
}
// data_sizes is one arrayList<Long>, t is tablet
def fetchDataSize = { data_sizes, t ->
def tabletId = t[0]
String meta_url = t[17]
def fetchDataSize = {List<Long> data_sizes, Map<String, Object> t ->
def tabletId = t.TabletId
String meta_url = t.MetaUrl
def clos = { respCode, body ->
logger.info("test ttl expired resp Code {}", "${respCode}".toString())
assertEquals("${respCode}".toString(), "200")
Expand Down Expand Up @@ -134,7 +134,7 @@ suite("add_drop_partition_by_hdfs") {
"""

// show tablets from table, 获取第一个tablet的 LocalDataSize1
def tablets = sql """
def tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
log.info( "test tablets not empty")
Expand All @@ -152,15 +152,15 @@ suite("add_drop_partition_by_hdfs") {
sleep(600000)


tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
log.info( "test tablets not empty")
fetchDataSize(sizes, tablets[0])
while (sizes[1] == 0) {
log.info( "test remote size is zero, sleep 10s")
sleep(10000)
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
fetchDataSize(sizes, tablets[0])
Expand All @@ -172,7 +172,7 @@ suite("add_drop_partition_by_hdfs") {
while (RemoteDataSize1 != originLocalDataSize1 && sleepTimes < 60) {
log.info( "test remote size is same with origin size, sleep 10s")
sleep(10000)
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
fetchDataSize(sizes, tablets[0])
Expand Down
16 changes: 8 additions & 8 deletions regression-test/suites/cold_heat_separation_p2/create_table_use_dynamic_partition.groovy
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,9 +33,9 @@ suite("cold_heat_dynamic_partition") {
}
}
// data_sizes is one arrayList<Long>, t is tablet
def fetchDataSize = { data_sizes, t ->
def tabletId = t[0]
String meta_url = t[17]
def fetchDataSize = {List<Long> data_sizes, Map<String, Object> t ->
def tabletId = t.TabletId
String meta_url = t.MetaUrl
def clos = { respCode, body ->
logger.info("test ttl expired resp Code {}", "${respCode}".toString())
assertEquals("${respCode}".toString(), "200")
Expand Down Expand Up @@ -146,7 +146,7 @@ suite("cold_heat_dynamic_partition") {
"""

// show tablets from table, 获取第一个tablet的 LocalDataSize1
def tablets = sql """
def tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
log.info( "test tablets not empty")
Expand All @@ -164,15 +164,15 @@ suite("cold_heat_dynamic_partition") {
sleep(600000)


tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
log.info( "test tablets not empty")
fetchDataSize(sizes, tablets[0])
while (sizes[1] == 0) {
log.info( "test remote size is zero, sleep 10s")
sleep(10000)
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
fetchDataSize(sizes, tablets[0])
Expand All @@ -184,7 +184,7 @@ suite("cold_heat_dynamic_partition") {
while (RemoteDataSize1 != originLocalDataSize1 && sleepTimes < 60) {
log.info( "test remote size is same with origin size, sleep 10s")
sleep(10000)
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM
"""
fetchDataSize(sizes, tablets[0])
Expand Down Expand Up @@ -280,4 +280,4 @@ suite("cold_heat_dynamic_partition") {



}
}
14 changes: 7 additions & 7 deletions ...ion-test/suites/cold_heat_separation_p2/create_table_use_dynamic_partition_by_hdfs.groovy
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,9 +33,9 @@ suite("cold_heat_dynamic_partition_by_hdfs") {
}
}
// data_sizes is one arrayList<Long>, t is tablet
def fetchDataSize = { data_sizes, t ->
def tabletId = t[0]
String meta_url = t[17]
def fetchDataSize = {List<Long> data_sizes, Map<String, Object> t ->
def tabletId = t.TabletId
String meta_url = t.MetaUrl
def clos = { respCode, body ->
logger.info("test ttl expired resp Code {}", "${respCode}".toString())
assertEquals("${respCode}".toString(), "200")
Expand Down Expand Up @@ -144,7 +144,7 @@ suite("cold_heat_dynamic_partition_by_hdfs") {
"""

// show tablets from table, 获取第一个tablet的 LocalDataSize1
def tablets = sql """
def tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
log.info( "test tablets not empty")
Expand All @@ -162,15 +162,15 @@ suite("cold_heat_dynamic_partition_by_hdfs") {
sleep(600000)


tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
log.info( "test tablets not empty")
fetchDataSize(sizes, tablets[0])
while (sizes[1] == 0) {
log.info( "test remote size is zero, sleep 10s")
sleep(10000)
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName}
"""
fetchDataSize(sizes, tablets[0])
Expand All @@ -182,7 +182,7 @@ suite("cold_heat_dynamic_partition_by_hdfs") {
while (RemoteDataSize1 != originLocalDataSize1 && sleepTimes < 60) {
log.info( "test remote size is same with origin size, sleep 10s")
sleep(10000)
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM
"""
fetchDataSize(sizes, tablets[0])
Expand Down
28 changes: 14 additions & 14 deletions regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy.groovy
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,9 +32,9 @@ suite("create_table_use_partition_policy") {
}
}
// data_sizes is one arrayList<Long>, t is tablet
def fetchDataSize = { data_sizes, t ->
def tabletId = t[0]
String meta_url = t[17]
def fetchDataSize = { List<Long> data_sizes, Map<String, Object> t ->
def tabletId = t.TabletId
String meta_url = t.MetaUrl
def clos = { respCode, body ->
assertEquals("${respCode}".toString(), "200")
String out = "${body}".toString()
Expand Down Expand Up @@ -194,7 +194,7 @@ suite("create_table_use_partition_policy") {
// sleep(30000);

// show tablets from table, 获取第一个tablet的 LocalDataSize1
def tablets = sql """
def tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName} PARTITIONS(p202301)
"""
log.info( "test tablets not empty")
Expand All @@ -212,15 +212,15 @@ suite("create_table_use_partition_policy") {
sleep(600000)


tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName} PARTITIONS(p202301)
"""
log.info( "test tablets not empty")
fetchDataSize(sizes, tablets[0])
while (sizes[1] == 0) {
log.info( "test remote size is zero, sleep 10s")
sleep(10000)
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName} PARTITIONS(p202301)
"""
fetchDataSize(sizes, tablets[0])
Expand All @@ -232,7 +232,7 @@ suite("create_table_use_partition_policy") {
while (RemoteDataSize1 != originLocalDataSize1 && sleepTimes < 60) {
log.info( "test remote size is same with origin size, sleep 10s")
sleep(10000)
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName} PARTITIONS(p202301)
"""
fetchDataSize(sizes, tablets[0])
Expand All @@ -245,7 +245,7 @@ suite("create_table_use_partition_policy") {
log.info( "test remote size not zero")
assertEquals(RemoteDataSize1, originLocalDataSize1)

tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName} PARTITIONS(p202302)
"""
log.info( "test tablets not empty")
Expand Down Expand Up @@ -298,7 +298,7 @@ suite("create_table_use_partition_policy") {
load_lineitem_table()

// show tablets from table, 获取第一个tablet的 LocalDataSize1
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName} PARTITIONS(p202301)
"""
log.info( "test tablets not empty")
Expand All @@ -316,15 +316,15 @@ suite("create_table_use_partition_policy") {
sleep(600000)


tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName} PARTITIONS(p202301)
"""
log.info( "test tablets not empty")
fetchDataSize(sizes, tablets[0])
while (sizes[1] == 0) {
log.info( "test remote size is zero, sleep 10s")
sleep(10000)
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName} PARTITIONS(p202301)
"""
fetchDataSize(sizes, tablets[0])
Expand All @@ -336,7 +336,7 @@ suite("create_table_use_partition_policy") {
while (RemoteDataSize1 != originLocalDataSize1 && sleepTimes < 60) {
log.info( "test remote size is same with origin size, sleep 10s")
sleep(10000)
tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName} PARTITIONS(p202301)
"""
fetchDataSize(sizes, tablets[0])
Expand All @@ -349,7 +349,7 @@ suite("create_table_use_partition_policy") {
log.info( "test remote size not zero")
assertEquals(RemoteDataSize1, originLocalDataSize1)

tablets = sql """
tablets = sql_return_maparray """
SHOW TABLETS FROM ${tableName} PARTITIONS(p202302)
"""
log.info( "test tablets not empty")
Expand All @@ -369,4 +369,4 @@ suite("create_table_use_partition_policy") {



}
}
Loading
Loading