hawk9821 opened a new issue, #5110: URL: https://github.com/apache/paimon/issues/5110
### Search before asking - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version 0.7.0-incubating 1.0.1 ### Compute Engine JavaAPI ### Minimal reproduce step step1. create table using version 0.7.0-incubating ``` package com.hawk.paimon; import org.apache.paimon.catalog.Catalog; import org.apache.paimon.catalog.CatalogContext; import org.apache.paimon.catalog.CatalogFactory; import org.apache.paimon.catalog.Identifier; import org.apache.paimon.fs.Path; import org.apache.paimon.schema.Schema; import org.apache.paimon.table.Table; import org.apache.paimon.types.DataTypes; import java.util.List; import java.util.concurrent.TimeUnit; public class CreateTable { public static String tableName = "paimon_version_07"; public static void main(String[] args) { CatalogContext catalogContext = CatalogContext.create(new Path("file:///tmp/paimon_version")); try (Catalog catalog = CatalogFactory.createCatalog(catalogContext)){ Identifier identifier = Identifier.create("test",tableName); List<String> databases = catalog.listDatabases(); if (!databases.contains(identifier.getDatabaseName())){ catalog.createDatabase(identifier.getDatabaseName(), false); } List<String> tables = catalog.listTables(identifier.getDatabaseName()); if (!tables.contains(identifier.getObjectName())){ Schema.Builder schemaBuilder = Schema.newBuilder(); schemaBuilder.column("id", DataTypes.SMALLINT()); schemaBuilder.column("name", DataTypes.STRING()); schemaBuilder.column("age", DataTypes.TINYINT()); // schemaBuilder.primaryKey("id"); schemaBuilder.comment("changelog table"); catalog.createTable(identifier, schemaBuilder.build(), false); } TimeUnit.SECONDS.sleep(1); Table table = catalog.getTable(identifier); System.out.println("===============================\n" + table.rowType()); } catch (Exception e) { throw new RuntimeException(e); } } } ``` step2. run the above code again using version 1.0.1 throw exception ``` Caused by: java.lang.RuntimeException: You should define a 'bucket-key' for bucketed append mode. at org.apache.paimon.schema.SchemaValidation.validateBucket(SchemaValidation.java:581) at org.apache.paimon.schema.SchemaValidation.validateTableSchema(SchemaValidation.java:99) at org.apache.paimon.table.AbstractFileStoreTable.copyInternal(AbstractFileStoreTable.java:351) at org.apache.paimon.table.AbstractFileStoreTable.copy(AbstractFileStoreTable.java:295) at org.apache.paimon.table.FileStoreTableFactory.createWithoutFallbackBranch(FileStoreTableFactory.java:127) at org.apache.paimon.table.FileStoreTableFactory.create(FileStoreTableFactory.java:90) at org.apache.paimon.table.FileStoreTableFactory.create(FileStoreTableFactory.java:80) at org.apache.paimon.catalog.AbstractCatalog.getDataOrFormatTable(AbstractCatalog.java:423) at org.apache.paimon.catalog.AbstractCatalog.getTable(AbstractCatalog.java:415) at org.apache.paimon.catalog.CachingCatalog.getTable(CachingCatalog.java:254) at com.hawk.paimon.CreateTable.main(CreateTable.java:37) ``` ### What doesn't meet your expectations? Primary key table is ok APPendOnly table throw exception version 0.8 and above is ok ### Anything else? _No response_ ### Are you willing to submit a PR? - [ ] I'm willing to submit a PR! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
