Skip to content

Commit 9b92048

Browse files
fix IcebergMetadataApplier
1 parent 15ce2dc commit 9b92048

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergMetadataApplier.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -124,6 +124,9 @@ public void applySchemaChange(SchemaChangeEvent schemaChangeEvent)
124124
},
125125
truncateTableEvent -> {
126126
throw new UnsupportedSchemaChangeEventException(truncateTableEvent);
127+
},
128+
alterTableEvent -> {
129+
throw new UnsupportedSchemaChangeEventException(alterTableEvent);
127130
});
128131
}
129132

0 commit comments

Comments
 (0)