[jira] [Updated] (HUDI-7213) When using wrong tabe.type value in hudi catalog happends npe

["jack Lei (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/HUDI-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

jack Lei updated HUDI-7213:
---------------------------
    Description: 
 
{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}
 
       Priority: Trivial  (was: Major)
        Summary:  When using wrong tabe.type value in hudi catalog happends npe  (was:  When using hudi)

>  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
>
>  
> {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)