hadoop - Hive 插入查询失败并返回错误代码 -101

Question

我正在尝试运行一个简单的插入语句，如下所示：

insert into table `bwc_test` partition(call_date)
select * from
`bwc_master`; 

然后它失败并出现以下错误：

信息：从 /apps/hive/warehouse/dtc.db/bwc_test/.hive-staging_hive_2018-11-13_19-10-37_084_8697431764330812894-1/-ext-10000 将数据加载到表 dtc.bwc_test 分区（call_date=null）

Error: Error while processing statement: FAILED: Execution Error, return code -101 from org.apache.hadoop.hive.ql.exec.MoveTask. HIVE_LOAD_DYNAMIC_PARTITIONS_THREAD_COUNT (state=08S01,code=-101)

bwc_master 的表定义：

CREATE TABLE `bwc_master`(                                   
unique_id bigint,                                           
customer_id string,                                         
direction string,                                           
call_date_time timestamp,                                   
duration int,                                               
billed_duration int,                                        
retail_rate decimal(9,7),                                   
retail_cost decimal(19,7),                                  
billed_tier smallint,                                       
call_type tinyint,                                          
record_status tinyint,                                      
aggregate_id bigint,                                        
originating_ipaddress string,                               
originating_number string,                                  
destination_number string,                                  
lrn string,                                                 
ocn string,                                                 
destination_rate_center string,                             
destination_lata int,                                       
billed_prefix string,                                       
rate_id string,                                             
wholesale_rate decimal(9,7),                                
wholesale_cost decimal(19,7),                               
cnam_dipped boolean,                                        
billed_number_type tinyint,                                 
source_lata int,                                            
source_ocn string,                                          
location_id string,                                         
sippeer_id int,                                             
rate_attempts tinyint,                                      
source_state string,                                        
source_rc string,                                           
destination_country string,                                 
destination_state string,                                   
destination_ip string,                                      
carrier_id string,                                          
rated_date_time timestamp,                                  
partition_id smallint,                                      
encryption_rate decimal(9,7),                               
encryption_cost decimal(19,7),                              
trans_coding_rate decimal(9,7),                             
trans_coding_cost decimal(19,7),                            
file_name string,                                           
call_id string,                                             
from_tag string,                                            
to_tag string,                                              
unique_record_id string)                                    

PARTITIONED BY (                                                
`call_date` date)  

CLUSTERED BY (                                                  
customer_id)                                                  
INTO 10 BUCKETS 

ROW FORMAT SERDE                                                
 'org.apache.hadoop.hive.ql.io.orc.OrcSerde'  

STORED AS INPUTFORMAT                                           
'org.apache.hadoop.hive.ql.io.orc.OrcInputFormat'

OUTPUTFORMAT                                                    
'org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat'    

LOCATION                                                        
'hdfs://*****/apps/hive/warehouse/dtc.db/bwc_master'  

有人可以帮我调试吗？我在日志中没有找到任何东西。

Answer 1

你之前错过了“桌子”bwc_test

insert into  table `bwc_test` partition(call_date)
select * from
`bwc_master`;