From 6bedcb2255b6d5b0bf6ba06718147f3a5af6d30a Mon Sep 17 00:00:00 2001 From: Ruoxi Sun Date: Sat, 11 May 2024 02:22:55 +0800 Subject: [PATCH] Refine --- cpp/src/arrow/acero/asof_join_node.cc | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/cpp/src/arrow/acero/asof_join_node.cc b/cpp/src/arrow/acero/asof_join_node.cc index c8b733cb58445..bff230cfac14c 100644 --- a/cpp/src/arrow/acero/asof_join_node.cc +++ b/cpp/src/arrow/acero/asof_join_node.cc @@ -972,10 +972,9 @@ class AsofJoinNode : public ExecNode { // If LHS is finished or empty then there's nothing we can do here if (lhs.Finished() || lhs.Empty()) break; - ARROW_ASSIGN_OR_RAISE(auto pair, UpdateRhsAndCheckUpToDateWithLhs()); bool any_rhs_advanced{}; bool rhs_up_to_date_with_lhs{}; - std::tie(any_rhs_advanced, rhs_up_to_date_with_lhs) = pair; + ARROW_ASSIGN_OR_RAISE(std::tie(any_rhs_advanced, rhs_up_to_date_with_lhs), UpdateRhsAndCheckUpToDateWithLhs()); // If we have received enough inputs to produce the next output batch // (decided by IsUpToDateWithLhsRow), we will perform the join and