From 0ace4bea272011cbf8eb998e553e5ae37fd1a6b0 Mon Sep 17 00:00:00 2001 From: xxhZs <1060434431@qq.com> Date: Thu, 19 Sep 2024 18:26:06 +0800 Subject: [PATCH] fix ci rename --- e2e_test/iceberg/test_case/iceberg_source_all_delete.slt | 5 +++-- e2e_test/iceberg/test_case/iceberg_source_all_delete.toml | 4 ++-- .../iceberg/test_case/iceberg_source_equality_delete.slt | 4 ++-- .../iceberg/test_case/iceberg_source_equality_delete.toml | 4 ++-- .../iceberg/test_case/iceberg_source_position_delete.slt | 5 +++-- .../iceberg/test_case/iceberg_source_position_delete.toml | 4 ++-- 6 files changed, 14 insertions(+), 12 deletions(-) diff --git a/e2e_test/iceberg/test_case/iceberg_source_all_delete.slt b/e2e_test/iceberg/test_case/iceberg_source_all_delete.slt index 4ea84f0f17bcd..4f4d6279fc9c8 100644 --- a/e2e_test/iceberg/test_case/iceberg_source_all_delete.slt +++ b/e2e_test/iceberg/test_case/iceberg_source_all_delete.slt @@ -13,7 +13,7 @@ CREATE SINK sink1 AS select * from mv1 WITH ( connector = 'iceberg', type = 'upsert', database.name = 'demo_db', - table.name = 't1', + table.name = 'test_all_delete', catalog.name = 'demo', catalog.type = 'storage', warehouse.path = 's3a://icebergdata/demo', @@ -22,6 +22,7 @@ CREATE SINK sink1 AS select * from mv1 WITH ( s3.access.key = 'hummockadmin', s3.secret.key = 'hummockadmin', create_table_if_not_exists = 'true', + commit_checkpoint_interval = 5, primary_key = 'i1,i2', ); @@ -52,7 +53,7 @@ WITH ( catalog.type = 'storage', warehouse.path = 's3a://icebergdata/demo', database.name = 'demo_db', - table.name = 't1', + table.name = 'test_all_delete', ); statement ok diff --git a/e2e_test/iceberg/test_case/iceberg_source_all_delete.toml b/e2e_test/iceberg/test_case/iceberg_source_all_delete.toml index 0aa32960e308e..220eeb03a3310 100644 --- a/e2e_test/iceberg/test_case/iceberg_source_all_delete.toml +++ b/e2e_test/iceberg/test_case/iceberg_source_all_delete.toml @@ -1,11 +1,11 @@ init_sqls = [ 'CREATE SCHEMA IF NOT EXISTS demo_db', - 'DROP TABLE IF EXISTS demo_db.t1', + 'DROP TABLE IF EXISTS demo_db.test_all_delete', ] slt = 'test_case/iceberg_source_equality_delete.slt' drop_sqls = [ - 'DROP TABLE IF EXISTS demo_db.t1', + 'DROP TABLE IF EXISTS demo_db.test_all_delete', 'DROP SCHEMA IF EXISTS demo_db', ] \ No newline at end of file diff --git a/e2e_test/iceberg/test_case/iceberg_source_equality_delete.slt b/e2e_test/iceberg/test_case/iceberg_source_equality_delete.slt index e4200b085ca14..975ced803d1f2 100644 --- a/e2e_test/iceberg/test_case/iceberg_source_equality_delete.slt +++ b/e2e_test/iceberg/test_case/iceberg_source_equality_delete.slt @@ -16,7 +16,7 @@ CREATE SINK sink1 AS select * from mv1 WITH ( connector = 'iceberg', type = 'upsert', database.name = 'demo_db', - table.name = 't1', + table.name = 'test_equality_delete', catalog.name = 'demo', catalog.type = 'storage', warehouse.path = 's3a://icebergdata/demo', @@ -59,7 +59,7 @@ WITH ( catalog.type = 'storage', warehouse.path = 's3a://icebergdata/demo', database.name = 'demo_db', - table.name = 't1', + table.name = 'test_equality_delete', ); query I diff --git a/e2e_test/iceberg/test_case/iceberg_source_equality_delete.toml b/e2e_test/iceberg/test_case/iceberg_source_equality_delete.toml index 0aa32960e308e..e28b4d406a297 100644 --- a/e2e_test/iceberg/test_case/iceberg_source_equality_delete.toml +++ b/e2e_test/iceberg/test_case/iceberg_source_equality_delete.toml @@ -1,11 +1,11 @@ init_sqls = [ 'CREATE SCHEMA IF NOT EXISTS demo_db', - 'DROP TABLE IF EXISTS demo_db.t1', + 'DROP TABLE IF EXISTS demo_db.test_equality_delete', ] slt = 'test_case/iceberg_source_equality_delete.slt' drop_sqls = [ - 'DROP TABLE IF EXISTS demo_db.t1', + 'DROP TABLE IF EXISTS demo_db.test_equality_delete', 'DROP SCHEMA IF EXISTS demo_db', ] \ No newline at end of file diff --git a/e2e_test/iceberg/test_case/iceberg_source_position_delete.slt b/e2e_test/iceberg/test_case/iceberg_source_position_delete.slt index a99ee36c88837..40d665d7144e3 100644 --- a/e2e_test/iceberg/test_case/iceberg_source_position_delete.slt +++ b/e2e_test/iceberg/test_case/iceberg_source_position_delete.slt @@ -13,7 +13,7 @@ CREATE SINK sink1 AS select * from mv1 WITH ( connector = 'iceberg', type = 'upsert', database.name = 'demo_db', - table.name = 't1', + table.name = 'test_position_delete', catalog.name = 'demo', catalog.type = 'storage', warehouse.path = 's3a://icebergdata/demo', @@ -22,6 +22,7 @@ CREATE SINK sink1 AS select * from mv1 WITH ( s3.access.key = 'hummockadmin', s3.secret.key = 'hummockadmin', create_table_if_not_exists = 'true', + commit_checkpoint_interval = 5, primary_key = 'i1,i2', ); @@ -52,7 +53,7 @@ WITH ( catalog.type = 'storage', warehouse.path = 's3a://icebergdata/demo', database.name = 'demo_db', - table.name = 't1', + table.name = 'test_position_delete', ); query I diff --git a/e2e_test/iceberg/test_case/iceberg_source_position_delete.toml b/e2e_test/iceberg/test_case/iceberg_source_position_delete.toml index caafa9d8137ed..398d6546ffa3f 100644 --- a/e2e_test/iceberg/test_case/iceberg_source_position_delete.toml +++ b/e2e_test/iceberg/test_case/iceberg_source_position_delete.toml @@ -1,11 +1,11 @@ init_sqls = [ 'CREATE SCHEMA IF NOT EXISTS demo_db', - 'DROP TABLE IF EXISTS demo_db.t1', + 'DROP TABLE IF EXISTS demo_db.test_position_delete', ] slt = 'test_case/iceberg_source_position_delete.slt' drop_sqls = [ - 'DROP TABLE IF EXISTS demo_db.t1', + 'DROP TABLE IF EXISTS demo_db.test_position_delete', 'DROP SCHEMA IF EXISTS demo_db', ] \ No newline at end of file