Skip to content

Commit

Permalink
fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
seawinde committed Dec 19, 2024
1 parent 2732642 commit fcde599
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -214,7 +214,7 @@ public Plan visitLogicalTopN(LogicalTopN<? extends Plan> topN, DeepCopierContext
.map(o -> new OrderKey(ExpressionDeepCopier.INSTANCE.deepCopy(o.getExpr(), context),
o.isAsc(), o.isNullFirst()))
.collect(ImmutableList.toImmutableList());
return new LogicalTopN<>(orderKeys, topN.getLimit(), topN.getOffset(), child, false);
return new LogicalTopN<>(orderKeys, topN.getLimit(), topN.getOffset(), child, topN.isPushed());
}

@Override
Expand All @@ -241,7 +241,7 @@ public Plan visitLogicalPartitionTopN(LogicalPartitionTopN<? extends Plan> parti
.map(o -> (OrderExpression) ExpressionDeepCopier.INSTANCE.deepCopy(o, context))
.collect(ImmutableList.toImmutableList());
return new LogicalPartitionTopN<>(partitionTopN.getFunction(), partitionKeys, orderKeys,
partitionTopN.hasGlobalLimit(), partitionTopN.getPartitionLimit(), child, false);
partitionTopN.hasGlobalLimit(), partitionTopN.getPartitionLimit(), child, partitionTopN.isPushed());
}

@Override
Expand Down

0 comments on commit fcde599

Please sign in to comment.