Skip to content

Commit 557cd7c

Browse files
committed
refactor test code
1 parent a4af3e1 commit 557cd7c

2 files changed

Lines changed: 332 additions & 59 deletions

File tree

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: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -183,7 +183,6 @@ private void applyCreateTable(CreateTableEvent event) {
183183
catalog.createTable(
184184
tableIdentifier, icebergSchema, partitionSpec, tableOptions);
185185

186-
// Step3: Apply default values if any columns have them.
187186
applyDefaultValues(table, cdcSchema);
188187

189188
LOG.info(

0 commit comments

Comments
 (0)