Re: flink sql 1.11.1 could not insert hive orc record

Tue, 08 Sep 2020 01:56:10 -0700 

Hi ,我例子中的hive orc表，不是事务表，如图：

createtab_stmt  
CREATE TABLE `dest_orc`(        
  `i` int)      
PARTITIONED BY (        
  `ts` string)  
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://nameservice1/opt/user/hive/warehouse/dw.db/dest_orc'  
TBLPROPERTIES ( 
  'is_generic'='false',         
  'orc.compress'='SNAPPY',      
  'transient_lastDdlTime'='1599555226') 




--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复