Skip to content

Commit a9ac488

Browse files
committed
fix java8
1 parent b4f754e commit a9ac488

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

fluss-lake/fluss-lake-paimon/src/main/java/org/apache/fluss/lake/paimon/PaimonLakeCatalog.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -219,7 +219,7 @@ private Schema buildSchemaWithOptions(Schema schema, Map<String, String> options
219219
}
220220

221221
private void checkTableIsEmpty(Identifier tablePath, FileStoreTable table) {
222-
if (!table.latestSnapshot().isEmpty()) {
222+
if (table.latestSnapshot().isPresent()) {
223223
throw new TableAlreadyExistException(
224224
String.format(
225225
"The table %s already exists in Paimon catalog, and the table is not empty. "

0 commit comments

Comments
 (0)