[ https://issues.apache.org/jira/browse/HUDI-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
sivabalan narayanan closed HUDI-7213. ------------------------------------- Fix Version/s: 0.14.1 (was: 1.0.0) Resolution: Fixed > When using wrong tabe.type value in hudi catalog happends npe > -------------------------------------------------------------- > > Key: HUDI-7213 > URL: https://issues.apache.org/jira/browse/HUDI-7213 > Project: Apache Hudi > Issue Type: Bug > Reporter: jack Lei > Priority: Trivial > Labels: pull-request-available > Fix For: 0.14.1 > > > > {code:java} > --创建hudi res表 > create table IF NOT EXISTS hudi_catalog.tmp.test_metric_hudi_metastore_mor_new > ( > `id` string COMMENT 'id', > `name` string COMMENT '名称', > `pmerge` string COMMENT '合并字段', > dt string > ) PARTITIONED BY (dt) WITH > ( 'connector'='hudi', > 'table.type'='MERGE_ON_WRITE', > 'write.operation'='insert'); {code} > table.type is wrong > then appears > {code:java} > Caused by: org.apache.hudi.exception.HoodieCatalogException: Failed to create > table tmp.test_metric_hudi_metastore_mor_new at > org.apache.hudi.table.catalog.HoodieHiveCatalog.createTable(HoodieHiveCatalog.java:480) > at > org.apache.flink.table.catalog.CatalogManager.lambda$createTable$10(CatalogManager.java:661) > at > org.apache.flink.table.catalog.CatalogManager.execute(CatalogManager.java:841) > ... 22 moreCaused by: java.lang.NullPointerException at > java.util.HashMap.merge(HashMap.java:1225) at > java.util.stream.Collectors.lambda$toMap$58(Collectors.java:1320) at > java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169) at > java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175) > at java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1699) > at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481) > at > java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471) > at > java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) > at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) > at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499) > at > org.apache.hudi.table.catalog.TableOptionProperties.translateFlinkTableProperties2Spark(TableOptionProperties.java:191) > at > org.apache.hudi.table.catalog.HoodieHiveCatalog.instantiateHiveTable(HoodieHiveCatalog.java:610) > at > org.apache.hudi.table.catalog.HoodieHiveCatalog.createTable(HoodieHiveCatalog.java:469) > ... 24 more {code} > -- This message was sent by Atlassian Jira (v8.20.10#820010)