Failed to breakup Windowing invocations into Groups. error: org.apache.hadoop.hive.ql.parse

Question

我正在尝试连接来自两个 table 的两列，以生成一列的唯一 id.Max 列值和另一列的行号 table。

select (MAX(S.m_id))from MPPO S;
select row_number() OVER(ORDER BY G.a,G.r,G.f1,STG.filler2,G.n_p,G.fe,G.se) 
FROM mmp G
LEFT OUTER JOIN mppo S
ON TRIM(G.pc) = S.pc;

但是当将这两个查询组合如下时：

select (MAX(S.m_id))+ row_number() OVER(ORDER BY G.a,G.r,G.f1,STG.filler2,G.n_p,G.fe,G.se) 
FROM mmp G LEFT OUTER JOIN mppo S
ON TRIM(G.pc) = S.pc;

我收到以下错误：

SemanticException Failed to breakup Windowing invocations into Groups. At least 1 group
must only depend on input columns. Also check for circular dependencies. Underlying error:
org.apache.hadoop.hive.ql.parse.SemanticException

我做错了什么？请帮忙

Answer 1

Select 分别从每个表中获取 id 然后连接输出：

select concat(t.id,'',t1.id) from (select MAX(S.m_id) as id from MPPO s) t join (
select row_number() OVER(ORDER BY G.a,G.r,G.f1,STG.filler2,G.n_p,G.fe,G.se)  as id
FROM mmp G
LEFT OUTER JOIN mppo S
ON TRIM(G.pc) = S.pc) t1 on 1=1

Answer 2

我在 Hive 中遇到了类似的问题。我想分享我的经验，以防万一有人遇到类似问题

select 语句具有以下分区子句

COUNT () OVER (PARTITION BY mc.source_well_key, mc.report_dt order by mc.report_dt ) AS r_number

正确的语法是

replace count() with count(1) or count(*)

Failed to breakup Windowing invocations into Groups. error: org.apache.hadoop.hive.ql.parse

Failed to breakup Windowing invocations into Groups. error: org.apache.hadoop.hive.ql.parse

hadoop

hive

hiveql