You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "YangXuan (Jira)" <ji...@apache.org> on 2022/05/13 06:43:00 UTC
[jira] [Updated] (HUDI-4093) If the value of the partition column is null or abnormal, the insert operation throws NPE.
[ https://issues.apache.org/jira/browse/HUDI-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
YangXuan updated HUDI-4093:
---------------------------
Description:
1、First，we need to create a hudi table by spark-sql command like this:
create table hudi_test (id int, comb long, name string, mark string, salary double, time timestamp, dt date) using hudi partitioned by(dt) options(primaryKey='id', preCombineField='comb');
2、Then, we insert three records into the table like this:
insert into hudi_test3 values (1,10,'张三','总裁',999999.99,'2021-09-06 19:43:00','2021-09-06'),(2,20,'李四','秘书',8888.88,'2021-09-06 19:44:00','2021-09-06'),(3,30,'王五',null,null,null,null);
3、After performing steps 1 and 2, we will encounter NPE
> If the value of the partition column is null or abnormal, the insert operation throws NPE.
> ------------------------------------------------------------------------------------------
>
> Key: HUDI-4093
> URL: https://issues.apache.org/jira/browse/HUDI-4093
> Project: Apache Hudi
> Issue Type: Bug
> Reporter: YangXuan
> Priority: Major
>
> 1、First，we need to create a hudi table by spark-sql command like this:
> create table hudi_test (id int, comb long, name string, mark string, salary double, time timestamp, dt date) using hudi partitioned by(dt) options(primaryKey='id', preCombineField='comb');
> 2、Then, we insert three records into the table like this:
> insert into hudi_test3 values (1,10,'张三','总裁',999999.99,'2021-09-06 19:43:00','2021-09-06'),(2,20,'李四','秘书',8888.88,'2021-09-06 19:44:00','2021-09-06'),(3,30,'王五',null,null,null,null);
> 3、After performing steps 1 and 2, we will encounter NPE
--
This message was sent by Atlassian Jira
(v8.20.7#820007)