From a6a9495390dc57af1649a18b601546219d445878 Mon Sep 17 00:00:00 2001 From: kamilt Date: Wed, 30 Oct 2024 10:14:43 +0000 Subject: [PATCH] Check if process_thread_ is running before attempting to join --- cpp/src/arrow/acero/asof_join_node.cc | 2 ++ 1 file changed, 2 insertions(+) diff --git a/cpp/src/arrow/acero/asof_join_node.cc b/cpp/src/arrow/acero/asof_join_node.cc index c4f11d01f3d5c..d8523a074b21d 100644 --- a/cpp/src/arrow/acero/asof_join_node.cc +++ b/cpp/src/arrow/acero/asof_join_node.cc @@ -1136,7 +1136,9 @@ class AsofJoinNode : public ExecNode { virtual ~AsofJoinNode() { #ifdef ARROW_ENABLE_THREADING PushProcess(false); + if(process_thread_.joinable()){ process_thread_.join(); + } #endif }