1.创建了一个 impala EXTERNAL table: ENTRY_WORKFLOW_EX
语句如下:
[mw_shl_code=sql,true]drop table if exists ENTRY_WORKFLOW_EX;
CREATE EXTERNAL TABLE ENTRY_WORKFLOW_EX (
字段
)
ROW FORMAT DELIMITED
FIELDS TERMINATED BY '\001'
LOCATION '/user/sqoop/H2KYD_DB/entry_workflow/';[/mw_shl_code]
2.创建了一个kudu表 : ENTRY_WORKFLOW
语句如下:
[mw_shl_code=sql,true]drop table if exists ENTRY_WORKFLOW;
CREATE TABLE ENTRY_WORKFLOW(
字段,
PRIMARY KEY (ENTRY_WORKFLOW_ID)
)
PARTITION BY HASH(ID) PARTITIONS 7
STORED AS KUDU;[/mw_shl_code]
3. 通过语句 从 ENTRY_WORKFLOW_EX 表向 ENTRY_WORKFLOW插数据:
insert into ENTRY_WORKFLOW select * from ENTRY_WORKFLOW_EX;
4.最后错误信息如下
Query: insert into ENTRY_WORKFLOW select * from ENTRY_WORKFLOW_EX;
Query submitted at: 2017-09-29 11:46:36 (Coordinator: http://Eqbigdata10:25000)
Query progress can be monitored at: http://Eqbigdata10:25000/query_plan?query_id=4949906f8384fe2f:1540408500000000
WARNINGS: Row with null value violates nullability constraint on table 'impala::H2KYD_DB.ENTRY_WORKFLOW'. (1 of 3614 similar)
Modified 13915661 row(s), 3614 row error(s) in 33.93s
--------------------------------------------------------------------------------------------------
最后显示了 3641 row 有错误,现在我想知道 怎么去找到这三千多条错误的数据。
请各位前辈指教 谢谢!
|
|