From f91f1674612273dbe83a6735fe2473f5dec9407c Mon Sep 17 00:00:00 2001 From: "helloliuxg@gmail.com" Date: Wed, 1 Jan 2025 17:21:05 +0800 Subject: [PATCH] remove Catalog.ColumnAlreadyExistException when apply applyAddColumnEventWithPosition in paimon. because use may create table already before with the target column. --- .../flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java | 1 - 1 file changed, 1 deletion(-) diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java index bf9907b9073..2cc4327e120 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java @@ -316,7 +316,6 @@ private void applyRenameColumn(RenameColumnEvent event) throws SchemaEvolveExcep } catch (Catalog.TableNotExistException | Catalog.ColumnAlreadyExistException | Catalog.ColumnNotExistException e) { - throw new SchemaEvolveException(event, e.getMessage(), e); } }