fix

zml1206 · zml1206 · commit e2b7038a398a · 2026-03-05T10:43:24.000+08:00
diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/source/parser/ColumnDefinitionParserListener.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/source/parser/ColumnDefinitionParserListener.java
@@ -46,7 +46,7 @@ public void enterColumnDef(PostgreSQLParser.ColumnDefContext ctx) {
         } else {
             columnEditor = Column.editor().name(ctx.getText());
         }
-        super.exitColumnDef(ctx);
+        super.enterColumnDef(ctx);
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ public void enterColumnDef(PostgreSQLParser.ColumnDefContext ctx) {`
`46`	`46`	`} else {`
`47`	`47`	`columnEditor = Column.editor().name(ctx.getText());`
`48`	`48`	`}`
`49`		`- super.exitColumnDef(ctx);`
	`49`	`+ super.enterColumnDef(ctx);`
`50`	`50`	`}`
`51`	`51`
`52`	`52`	`@Override`