File tree Expand file tree Collapse file tree 1 file changed +15
-0
lines changed Expand file tree Collapse file tree 1 file changed +15
-0
lines changed Original file line number Diff line number Diff line change 118
118
qq( 1|1|1) ,
119
119
' check replicated inserts on subscriber' );
120
120
121
+ # Test if the expected error is reported when the subscriber table is missing
122
+ # columns which were specified on the publisher table.
123
+ $node_publisher -> safe_psql(' postgres' ,
124
+ " CREATE TABLE test_tab3 (a int, b int, c int)" );
125
+ $node_subscriber -> safe_psql(' postgres' , " CREATE TABLE test_tab3 (a int)" );
126
+
127
+ my $offset = -s $node_subscriber -> logfile;
128
+
129
+ $node_subscriber -> safe_psql(' postgres' ,
130
+ " ALTER SUBSCRIPTION tap_sub REFRESH PUBLICATION" );
131
+
132
+ $node_subscriber -> wait_for_log(
133
+ qr / ERROR: ( [A-Z0-9]+:)? logical replication target relation "public.test_tab3" is missing replicated columns: "b", "c"/ ,
134
+ $offset );
135
+
121
136
122
137
$node_subscriber -> stop;
123
138
$node_publisher -> stop;
You can’t perform that action at this time.
0 commit comments