Skip to content

Commit

Permalink
Check if process_thread_ is running before attempting to join
Browse files Browse the repository at this point in the history
  • Loading branch information
mroz45 committed Oct 30, 2024
1 parent 508eb2f commit a6a9495
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions cpp/src/arrow/acero/asof_join_node.cc
Original file line number Diff line number Diff line change
Expand Up @@ -1136,7 +1136,9 @@ class AsofJoinNode : public ExecNode {
virtual ~AsofJoinNode() {
#ifdef ARROW_ENABLE_THREADING
PushProcess(false);
if(process_thread_.joinable()){
process_thread_.join();
}
#endif
}

Expand Down

0 comments on commit a6a9495

Please sign in to comment.