Skip to content

Commit 721934a

Browse files
committed
fix
1 parent cef26d8 commit 721934a

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/resources/ddl/ddl_audit.sql

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
-- See the License for the specific language governing permissions and
1414
-- limitations under the License.
1515

16-
-- Create event listener table and associate it with event triggers to listen for ddl_command_end and sql_drop events
16+
-- Create event listener table and associate it with event triggers to listen for ddl_command_end and sql_drop events.
1717
DROP SCHEMA IF EXISTS audit CASCADE;
1818
CREATE SCHEMA audit;
1919

@@ -62,6 +62,9 @@ DECLARE
6262
BEGIN
6363
FOR r IN SELECT * FROM pg_event_trigger_dropped_objects()
6464
LOOP
65+
IF r.object_type = 'table column' THEN
66+
CONTINUE;
67+
END IF;
6568
IF r.schema_name = 'audit' AND r.object_identity LIKE 'audit.ddl_log%' THEN
6669
CONTINUE;
6770
END IF;

0 commit comments

Comments
 (0)