Skip to content

Commit b94d8c7

Browse files
committed
fix case
1 parent 63fd4f8 commit b94d8c7

File tree

1 file changed

+10
-5
lines changed

1 file changed

+10
-5
lines changed

paimon-core/src/test/java/org/apache/paimon/rest/RESTCatalogServer.java

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1028,11 +1028,16 @@ private MockResponse rollbackSchemaHandle(Identifier identifier, String data) th
10281028
FileStoreTable table = getFileTable(identifier);
10291029
long schemaId = requestBody.getSchemaId();
10301030
SchemaManager schemaManager = new SchemaManager(table.fileIO(), table.location());
1031-
schemaManager.rollbackTo(
1032-
schemaId,
1033-
table.snapshotManager(),
1034-
table.tagManager(),
1035-
new ChangelogManager(table.fileIO(), table.location(), null));
1031+
try {
1032+
schemaManager.rollbackTo(
1033+
schemaId,
1034+
table.snapshotManager(),
1035+
table.tagManager(),
1036+
new ChangelogManager(table.fileIO(), table.location(), null));
1037+
} catch (Exception e) {
1038+
return mockResponse(new ErrorResponse(null, null, e.getMessage(), 500), 500);
1039+
}
1040+
10361041
return new MockResponse().setResponseCode(200);
10371042
}
10381043

0 commit comments

Comments
 (0)