Skip to content

Commit f91f167

Browse files
remove Catalog.ColumnAlreadyExistException when apply applyAddColumnEventWithPosition in paimon. because use may create table already before with the target column.
1 parent 45f460e commit f91f167

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -316,7 +316,6 @@ private void applyRenameColumn(RenameColumnEvent event) throws SchemaEvolveExcep
316316
} catch (Catalog.TableNotExistException
317317
| Catalog.ColumnAlreadyExistException
318318
| Catalog.ColumnNotExistException e) {
319-
320319
throw new SchemaEvolveException(event, e.getMessage(), e);
321320
}
322321
}

0 commit comments

Comments
 (0)