HIVE: вставить перезаписать ошибку таблицы паркет - PullRequest
Новая
       11

HIVE: вставить перезаписать ошибку таблицы паркет

0 голосов
/ 17 мая 2018

Я просто делаю простой запрос, подобный этому, но появляются некоторые исключения. 

insert overwrite table stage_dfqp.user_currency partition (dt='2018-05-16')
select fuid,
       fbpid,
       fgamefsk
  from stage_dfqp.pb_gamecoins

введите описание изображения здесь но когда я изменяю запрос следующим образом (просто добавьте ограничение XXX), исключение исчезнет 

insert overwrite table stage_dfqp.user_currencypartition (dt='2018-05-16')
select fuid,
       fbpid,
       fgamefsk
  from stage_dfqp.pb_gamecoins limit 100

Таблица данных улья: 

CREATE TABLE `stage_dfqp.user_currency`(
  `fuid` bigint , 
  `coin_type` string , 
  `coin_num` bigint
)
PARTITIONED BY ( 
  `dt` string)
ROW FORMAT SERDE 
  'org.apache.hadoop.hive.ql.io.parquet.serde.ParquetHiveSerDe' 
STORED AS INPUTFORMAT 
  'org.apache.hadoop.hive.ql.io.parquet.MapredParquetInputFormat' 
OUTPUTFORMAT 
  'org.apache.hadoop.hive.ql.io.parquet.MapredParquetOutputFormat'
...