hadoop - 无法将窗口调用分解为组。至少 1 组必须仅依赖于输入列。同时检查循环依赖

Question

我试图以后代方式在更新日期之前对一组值进行排序，但我遇到了这个奇怪的错误:

Failed to breakup Windowing invocations into Groups. At least 1 group must only depend on input columns. Also check for circular dependencies.

我不确定这是什么意思，我有一个类似的行，上面有相同的代码并且它有效，不确定我是否不能有两次相同的分组代码。

  ROW_NUMBER() OVER (PARTITION BY user_id ORDER BY update_timestamp) as id_update

我希望它按 user_id 对它收到的不同更新进行分区。

Answer 1

发现问题，分组键必须是查询列表的一部分，这意味着 update_timestamp 必须是选择列表的一部分。

选择用户身份，更新时间戳， ROW_NUMBER() OVER (PARTITION BY user_id ORDER BY update_timestamp) 作为 id_update来自表a