Skip to content

Commit

Permalink
[fix](external-p2) ignore external p2 cases
Browse files Browse the repository at this point in the history
  • Loading branch information
morningman committed Sep 23, 2024
1 parent 48e60f3 commit 8794f7b
Show file tree
Hide file tree
Showing 24 changed files with 124 additions and 377 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,11 @@
// under the License.
//import org.postgresql.Driver
suite("test_external_catalog_es", "p2,external,es,external_remote,external_remote_es") {
Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}

String enabled = context.config.otherConfigs.get("enableExternalEsTest")
if (enabled != null && enabled.equalsIgnoreCase("true")) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,12 @@
// under the License.

suite("test_cloud_accessible_obs", "p2,external,hive,external_remote,external_remote_hive") {

Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}
String enabled = context.config.otherConfigs.get("enableObjStorageTest")
if (enabled != null && enabled.equalsIgnoreCase("true")) {
String extHiveHmsHost = context.config.otherConfigs.get("extHiveHmsHost")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,13 @@
// under the License.

suite("test_cloud_accessible_oss", "p2,external,hive,external_remote,external_remote_hive") {

Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}

String enabled = context.config.otherConfigs.get("enableObjStorageTest")
if (enabled != null && enabled.equalsIgnoreCase("true")) {
String extHiveHmsHost = context.config.otherConfigs.get("extHiveHmsHost")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,11 @@
// under the License.

suite("test_external_brown", "p2,external,hive,external_remote,external_remote_hive") {
Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}

def formats = ["_parquet", "_orc", ""]
def CPUNetworkUtilization_order = """
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,13 @@
// under the License.

suite("test_external_catalog_glue_table", "p2,external,hive,external_remote,external_remote_hive") {

Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}

String enabled = context.config.otherConfigs.get("enableExternalHiveTest")
if (enabled != null && enabled.equalsIgnoreCase("true")) {
String extHiveHmsHost = context.config.otherConfigs.get("extHiveHmsHost")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,11 @@
// under the License.

suite("test_external_github", "p2,external,hive,external_remote,external_remote_hive") {
Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}

def formats = ["_parquet", "_orc"]

Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,11 @@
// under the License.

suite("test_external_yandex_nereids", "p2,external,hive,external_remote,external_remote_hive") {
Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}

def formats = ["_parquet"]
def duplicateAggregationKeys = "SELECT URL, EventDate, max(URL) FROM hitsSUFFIX WHERE CounterID = 1704509 AND UserID = 4322253409885123546 GROUP BY URL, EventDate, EventDate ORDER BY URL, EventDate;"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,12 @@
// under the License.

suite("test_hive_hudi", "p2,external,hive,hudi") {

Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}
String enabled = context.config.otherConfigs.get("enableExternalHiveTest")
if (enabled != null && enabled.equalsIgnoreCase("true")) {
String extHiveHmsHost = context.config.otherConfigs.get("extHiveHmsHost")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,12 @@
// under the License.

suite("test_hive_hudi_statistics", "p2,external,hive,hudi") {

Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}
String enabled = context.config.otherConfigs.get("enableExternalHiveTest")
if (enabled != null && enabled.equalsIgnoreCase("true")) {
String extHiveHmsHost = context.config.otherConfigs.get("extHiveHmsHost")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,11 @@
// under the License.

suite("test_hive_partition_statistic", "p2,external,hive,external_remote,external_remote_hive") {
Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}
String enabled = context.config.otherConfigs.get("enableExternalHiveTest")
if (enabled != null && enabled.equalsIgnoreCase("true")) {
logger.info("This feature has not been supported yet, skip it.")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,12 @@

suite("test_hive_statistic_cache", "p2,external,hive,external_remote,external_remote_hive") {

Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}

def wait_row_count_reported = { table, expected ->
for (int i = 0; i < 10; i++) {
result = sql """show table stats ${table}"""
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,11 @@
// under the License.

suite("test_hive_statistic_sample", "p2,external,hive,external_remote,external_remote_hive") {
Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}
String enabled = context.config.otherConfigs.get("enableExternalHiveTest")
if (enabled != null && enabled.equalsIgnoreCase("true")) {
String extHiveHmsHost = context.config.otherConfigs.get("extHiveHmsHost")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,12 @@
// under the License.

suite("test_hive_write_insert_s3", "p2,external,hive,external_remote,external_remote_hive") {

Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}
def format_compressions = ["parquet_snappy"]
def s3BucketName = getS3BucketName()

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,13 @@
// under the License.

suite("test_select_count_optimize", "p2,external,hive,external_remote,external_remote_hive") {

Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}

String enabled = context.config.otherConfigs.get("enableExternalHiveTest")
if (enabled != null && enabled.equalsIgnoreCase("true")) {
String extHiveHmsHost = context.config.otherConfigs.get("extHiveHmsHost")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,12 @@
// under the License.

suite("upper_case_column_name", "p2,external,hive,external_remote,external_remote_hive") {

Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}
def hiveParquet1 = """select * from hive_upper_case_parquet;"""
def hiveParquet2 = """select * from hive_upper_case_parquet where id=1;"""
def hiveParquet3 = """select * from hive_upper_case_parquet where id>1;"""
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,11 @@
// under the License.

suite("test_viewfs_hive", "p2,external,hive,external_remote,external_remote_hive") {
Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}

String enabled = context.config.otherConfigs.get("enableExternalHiveTest")
if (enabled != null && enabled.equalsIgnoreCase("true")) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,12 @@

suite("test_hudi_timetravel", "p2,external,hudi,external_remote,external_remote_hudi") {

Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}

String enabled = context.config.otherConfigs.get("enableExternalHudiTest")
if (enabled == null || !enabled.equalsIgnoreCase("true")) {
logger.info("disable hudi test")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,12 @@
//import com.mysql.cj.jdbc.Driver
suite("test_external_catalog_mysql", "p2,external,mysql,external_remote,external_remote_mysql") {

Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}

String enabled = context.config.otherConfigs.get("enableExternalMysqlTest")
if (enabled != null && enabled.equalsIgnoreCase("true")) {
String extMysqlHost = context.config.otherConfigs.get("extMysqlHost")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,12 @@
//import com.mysql.cj.jdbc.Driver
suite("test_external_resource_mysql", "p2,external,mysql,external_remote,external_remote_mysql") {

Boolean ignoreP2 = true;
if (ignoreP2) {
logger.info("disable p2 test");
return;
}

String enabled = context.config.otherConfigs.get("enableExternalMysqlTest")
if (enabled != null && enabled.equalsIgnoreCase("true")) {
String extMysqlHost = context.config.otherConfigs.get("extMysqlHost")
Expand Down
Loading

0 comments on commit 8794f7b

Please sign in to comment.