Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
KeXiangWang committed Sep 21, 2024
1 parent 952e528 commit efc82e1
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 19 deletions.
10 changes: 0 additions & 10 deletions e2e_test/source/cdc/cdc.check_new_rows.slt
Original file line number Diff line number Diff line change
Expand Up @@ -375,13 +375,3 @@ SELECT * FROM partitioned_timestamp_table_shared ORDER BY c_boolean, c_int;
17 t 2024-09-07 16:45:00
18 t 2025-01-08 18:30:00
19 t 2025-07-09 07:10:00

query TTT
SELECT * FROM partitioned_timestamp_table_2023_shared ORDER BY c_boolean, c_int;
----
1 f 2023-02-01 10:30:00
2 f 2023-05-15 11:45:00
3 f 2023-11-03 12:15:00
11 t 2023-02-01 10:30:00
12 t 2023-05-15 11:45:00
13 t 2023-11-03 12:15:00
3 changes: 2 additions & 1 deletion e2e_test/source/cdc/cdc.load.slt
Original file line number Diff line number Diff line change
Expand Up @@ -259,6 +259,7 @@ create table upper_orders (
slot.name = 'orders'
);

# for the partitioned table
statement ok
CREATE TABLE IF NOT EXISTS partitioned_timestamp_table(
c_int int,
Expand All @@ -278,7 +279,7 @@ CREATE TABLE IF NOT EXISTS partitioned_timestamp_table(
slot.name = 'my_slot_partition'
);

# for only one partition
# for only one partition, as Postgres does not support adding both a partitioned tableand its individual partitions to the same publication, we use different publication for the partition
statement ok
CREATE TABLE IF NOT EXISTS partitioned_timestamp_table_2023(
c_int int,
Expand Down
8 changes: 0 additions & 8 deletions e2e_test/source/cdc/cdc.share_stream.slt
Original file line number Diff line number Diff line change
Expand Up @@ -296,14 +296,6 @@ CREATE TABLE partitioned_timestamp_table_shared(
PRIMARY KEY (c_int, c_timestamp)
) from pg_source table 'public.partitioned_timestamp_table';

statement ok
CREATE TABLE partitioned_timestamp_table_2023_shared(
c_int int,
c_boolean boolean,
c_timestamp timestamp,
PRIMARY KEY (c_int, c_timestamp)
) from pg_source table 'public.partitioned_timestamp_table_2023';

statement ok
CREATE MATERIALIZED VIEW person_new_cnt AS SELECT COUNT(*) AS cnt FROM person_new;

Expand Down

0 comments on commit efc82e1

Please sign in to comment.