remove Catalog.ColumnAlreadyExistException when apply applyAddColumnE…

…ventWithPosition in paimon. because use may create table already before with the target column.
apache · Jan 1, 2025 · 45f460e · 45f460e
1 parent 7025537
commit 45f460e
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...imon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java b/...imon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java
@@ -293,7 +293,11 @@ private void applyDropColumn(DropColumnEvent event) throws SchemaEvolveException
         } catch (Catalog.TableNotExistException
                 | Catalog.ColumnAlreadyExistException
                 | Catalog.ColumnNotExistException e) {
-            throw new SchemaEvolveException(event, e.getMessage(), e);
+            if (e instanceof Catalog.ColumnAlreadyExistException) {
+                LOG.warn("{}, skip it.", e.getMessage());
+            } else {
+                throw new SchemaEvolveException(event, e.getMessage(), e);
+            }
         }
     }
 
@@ -312,6 +316,7 @@ private void applyRenameColumn(RenameColumnEvent event) throws SchemaEvolveExcep
         } catch (Catalog.TableNotExistException
                 | Catalog.ColumnAlreadyExistException
                 | Catalog.ColumnNotExistException e) {
+
             throw new SchemaEvolveException(event, e.getMessage(), e);
         }
     }