NoSuchMethodError: org.apache.hadoop.hive.metastore.api.StorageDescriptor.setInputFormat[Bug]

[wudongdong00]

Search before asking

• I searched in the issues and found nothing similar.

Paimon version

0.7

Compute Engine

flin 1.14.6

Minimal reproduce step

CREATE CATALOG paimon_catalog WITH (
'type' = 'paimon',
'metastore' = 'hive',
'uri' = 'thrift://192.168.100.146:9083',
'metastore.partitioned-table' = 'true',
'location-in-properties' = 'true',
'table.type' = 'EXTERNAL'
);
USE CATALOG paimon_catalog;
CREATE TABLE my16 (
id BIGINT PRIMARY KEY NOT ENFORCED COMMENT 'ID' ,
name STRING COMMENT 'NAME' ,
zjhm STRING COMMENT 'ZJHM' ,
mz STRING COMMENT 'MZ' ,
age TINYINT COMMENT 'AGE' ,
sex TINYINT COMMENT 'SEX' ,
city STRING COMMENT 'CITY' ,
address STRING COMMENT 'ADDRESS' ,
jd DOUBLE COMMENT 'JD' ,
wd DOUBLE COMMENT 'WD' ,
lxdw STRING COMMENT 'LXDW' ,
costprice DOUBLE COMMENT 'COSTPRICE' ,
createtime TIMESTAMP COMMENT 'CREATETIME'
)
WITH (
'bucket' = '15',
'bucket-key' = 'id',
'changelog-producer' = 'input',
'num-sorted-run.compaction-trigger' = '10',
'write-buffer-size' = '1524mb',
'num-sorted-run.stop-trigger' = '2147483647',
'sort-spill-threshold' = '10',
'write-buffer-spillable' = 'true'
);

Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue.
at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:201)
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161)
Caused by: java.lang.NoSuchMethodError: org.apache.hadoop.hive.metastore.api.StorageDescriptor.setInputFormat(Ljava/lang/String;)V
at org.apache.paimon.hive.HiveCatalog.updateHmsTable(HiveCatalog.java:511)
at org.apache.paimon.hive.HiveCatalog.createTableImpl(HiveCatalog.java:383)
at org.apache.paimon.catalog.AbstractCatalog.createTable(AbstractCatalog.java:210)
at org.apache.paimon.flink.FlinkCatalog.createTable(FlinkCatalog.java:318)
at org.apache.flink.table.catalog.CatalogManager.lambda$createTable$10(CatalogManager.java:661)
at org.apache.flink.table.catalog.CatalogManager.execute(CatalogManager.java:841)
at org.apache.flink.table.catalog.CatalogManager.createTable(CatalogManager.java:659)
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:881)
at org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeOperation$3(LocalExecutor.java:209)
at org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88)

What doesn't meet your expectations?

can create table

Anything else?

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!