Skip to content

Commit

Permalink
update cdc test
Browse files Browse the repository at this point in the history
Signed-off-by: xxchan <[email protected]>
  • Loading branch information
xxchan committed Apr 24, 2024
1 parent 6cba758 commit 01ba723
Showing 1 changed file with 14 additions and 6 deletions.
20 changes: 14 additions & 6 deletions e2e_test/source_inline/cdc/mysql/mysql_create_drop.slt
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,20 @@ create source s with (

sleep 1s

# At the beginning, the source is paused. It will resume after a downstream is created.
system ok
internal_table.mjs --name s --type '' --count
----
count: 0


statement ok
create table tt1_shared (v1 int,
v2 timestamptz,
PRIMARY KEY (v1)
) from s table 'testdb1.tt1';

sleep 1s
# There's no data in upstream yet, but the offset is updated in the source executor via the heartbeat message.
system ok
internal_table.mjs --name s --type '' --count
Expand Down Expand Up @@ -116,12 +130,6 @@ create table tt5 (v1 int,
table.name = 'tt5',
);

statement ok
create table tt1_shared (v1 int,
v2 timestamptz,
PRIMARY KEY (v1)
) from s table 'testdb1.tt1';

statement ok
create table tt2_shared (v1 int,
v2 timestamptz,
Expand Down

0 comments on commit 01ba723

Please sign in to comment.