You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I use a postgres source to reproduce this. >>> means it should be executed in postgres.
# create table in pg
>>> create table src (v int primary key);
>>> insert into src values(10) (11) (12);
# connect to the pg table with pg-cdc
CREATE table src (v int primary key) WITH (
connector = 'postgres-cdc',
hostname = '127.0.0.1',
port = '5432',
username = 'postgresuser',
password = 'postgrespw',
slot.name = 'my_slot',
database.name = 'mydb',
table.name = 'src',
publication.name = 'rw_publication'
);
# stop the stream using rate limit
ALTER SOURCE src SET source_rate_limit TO 0;
# these data should not be in rw, as the streams has been stopped.
>>> insert into src values(20) (21) (22);
# return 3
select count( *) from mv;
# create a table and sink into the table with connector.
create table newdata(v int);
insert into newdata values(50);
create sink sk into src as select * from newdata;
# should return 4, but return 7
select count( *) from mv;
Expected behavior
No response
How did you deploy RisingWave?
No response
The version of RisingWave
No response
Additional context
No response
The text was updated successfully, but these errors were encountered:
Describe the bug
As titled.
Error message/log
To Reproduce
I use a postgres source to reproduce this.
>>>
means it should be executed in postgres.Expected behavior
No response
How did you deploy RisingWave?
No response
The version of RisingWave
No response
Additional context
No response
The text was updated successfully, but these errors were encountered: