回复：flink sql 1.11.1 could not insert hive orc record

Tue, 08 Sep 2020 01:59:20 -0700 

flink-orc模块版本应该只支持新版本，2.1.1支持不了，可以自己修改ORC源码


------------------------------------------------------------------
发件人：大罗 <[email protected]>
发送时间：2020年9月8日(星期二) 16:55
收件人：user-zh <[email protected]>
主　题：Re: flink sql 1.11.1 could not insert hive orc record

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/

回复