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

使用window函数：

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;