Skip to content

Commit 1f4f4c3

Browse files
committed
[kv] fix java8 compile
1 parent 4cba163 commit 1f4f4c3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

fluss-server/src/main/java/org/apache/fluss/server/utils/TableDescriptorValidation.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ private static void checkAutoIncColumns(
130130
}
131131
Optional<Schema.PrimaryKey> primaryKey =
132132
tableDescriptor.getSchema().getPrimaryKey();
133-
if (primaryKey.isEmpty()) {
133+
if (!primaryKey.isPresent()) {
134134
throw new InvalidTableException(
135135
"The AUTO_INCREMENT column is not supported in log table.");
136136
} else {

0 commit comments

Comments
 (0)