Skip to content

Commit f6fefbb

Browse files
committed
fix
1 parent 81a6f95 commit f6fefbb

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -563,17 +563,17 @@ public void rollbackTo(String tagName) {
563563

564564
@Override
565565
public void rollbackSchema(long schemaId) {
566-
LongConsumer schemaRollback = catalogEnvironment.catalogSchemaRollback();
567-
if (schemaRollback != null) {
568-
schemaRollback.accept(schemaId);
569-
} else {
570-
try {
571-
schemaManager()
572-
.rollbackTo(schemaId, snapshotManager(), tagManager(), changelogManager());
573-
} catch (IOException e) {
574-
throw new UncheckedIOException(e);
566+
LongConsumer schemaRollback = catalogEnvironment.catalogSchemaRollback();
567+
if (schemaRollback != null) {
568+
schemaRollback.accept(schemaId);
569+
} else {
570+
try {
571+
schemaManager()
572+
.rollbackTo(schemaId, snapshotManager(), tagManager(), changelogManager());
573+
} catch (IOException e) {
574+
throw new UncheckedIOException(e);
575+
}
575576
}
576-
}
577577
}
578578

579579
public Snapshot findSnapshot(long fromSnapshotId) throws SnapshotNotExistException {

0 commit comments

Comments
 (0)