SQL Не удалось выполнить запрос для Hive

Question

У меня следующий запрос, он не удался при попытке запустить его в Hive. Может ли кто-нибудь помочь мне восстановить его? Спасибо!

select topic, partition_c, untilOffset from playground.kafka_offset
where group_c = 'consumer-group-3' 
and commitTime = ( 
    select max(commitTime) 
    from playground.kafka_offset
    where group_c = 'consumer-group-3' 

Answer 1

Использовать оконные функции:

select topic, partition_c, untilOffset
from (select ko.*,
             max(commitTime) over (partition by group_c) as max_commitTime
      from playground.kafka_offset ko
      where group_c = 'consumer-group-3' 
     ) ko
where commitTime = max_commitTime;