Skip to content

Commit

Permalink
fix ci
Browse files Browse the repository at this point in the history
rename
  • Loading branch information
xxhZs committed Sep 19, 2024
1 parent 3137168 commit 0ace4be
Show file tree
Hide file tree
Showing 6 changed files with 14 additions and 12 deletions.
5 changes: 3 additions & 2 deletions e2e_test/iceberg/test_case/iceberg_source_all_delete.slt
Original file line number Diff line number Diff line change
Expand Up @@ -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',
Expand All @@ -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',
);

Expand Down Expand Up @@ -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
Expand Down
4 changes: 2 additions & 2 deletions e2e_test/iceberg/test_case/iceberg_source_all_delete.toml
Original file line number Diff line number Diff line change
@@ -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',
]
4 changes: 2 additions & 2 deletions e2e_test/iceberg/test_case/iceberg_source_equality_delete.slt
Original file line number Diff line number Diff line change
Expand Up @@ -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',
Expand Down Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
@@ -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',
]
5 changes: 3 additions & 2 deletions e2e_test/iceberg/test_case/iceberg_source_position_delete.slt
Original file line number Diff line number Diff line change
Expand Up @@ -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',
Expand All @@ -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',
);

Expand Down Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
@@ -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',
]

0 comments on commit 0ace4be

Please sign in to comment.