diff --git a/r/src/compute-exec.cpp b/r/src/compute-exec.cpp index 91d646f0a3c..889a79aff92 100644 --- a/r/src/compute-exec.cpp +++ b/r/src/compute-exec.cpp @@ -147,6 +147,8 @@ std::shared_ptr ExecPlan_read_table( return prepared_plan.second->ToTable(); }); + prepared_plan.first->StopProducing(); + StopIfNotOk(prepared_plan.first->finished().status()); return ValueOrStop(result); }