我猜你划分的列是倾斜的。你应该 group by 并计算要确认的行数。
如果确实发生了偏差，一般的优化方法是提前一个阶段，并尝试部分地聚合和减少数据。
根据您的情况，您可以尝试以下方法：
假设您的原始sql如下所示：

select * from (
    select 
        ca,
        cb,
        row_number() over(partition by ca order by cb desc) as rk1
    from my_table 
) tmp
where rk1 <=200;

优化版本如下：

with tt1 as(
    select 
        ca,
        cb,
        row_number() over(partition by ca, cast(rand()*20 as int) order by cb desc) as rk1 
    from my_table
)
select * from (
    select 
        ca,
        cb,
        row_number() over(partition by ca order by cb desc) as rk2
    from tt1
    where rk1 <= 200  
) tmp 
where rk2 <= 200;

当柱发生倾斜时 ca ，第二个sql预期比第一个sql快。在第一阶段，通过 cast(rand()*20 as int) . 在那之后， predicate where rk1 <= 200 执行，大大减少了以后要处理的数据。