Skip to content

Commit 639af09

Browse files
author
Rafał Hibner
committed
Fix UBSAN error
1 parent a4da91d commit 639af09

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

cpp/src/arrow/acero/asof_join_node_test.cc

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1692,7 +1692,9 @@ TEST(AsofJoinTest, PauseProducingAsofJoinSource) {
16921692
batch_producer_left.producer().Push(IterationEnd<std::optional<ExecBatch>>());
16931693
batch_producer_right.producer().Push(IterationEnd<std::optional<ExecBatch>>());
16941694

1695-
plan->StopProducing();
1695+
//finish gracefully
1696+
ASSERT_TRUE(batch_producer_left.producer().Close());
1697+
ASSERT_TRUE(batch_producer_right.producer().Close());
16961698

16971699
ASSERT_TRUE(fut.Wait(kDefaultAssertFinishesWaitSeconds));
16981700
if (!fut.status().ok()) {

0 commit comments

Comments
 (0)