Skip to content

Commit 7a097f3

Browse files
committed
[FLINK-36406] Add @OverRide to PaimonMetadataApplier#close
1 parent f800a47 commit 7a097f3

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
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: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -148,6 +148,7 @@ public void applySchemaChange(SchemaChangeEvent schemaChangeEvent)
148148
});
149149
}
150150

151+
@Override
151152
public void close() throws Exception {
152153
if (catalog != null) {
153154
catalog.close();

0 commit comments

Comments
 (0)