From e0fab9b1fc4c84aa1fd5029717ea40ee6fdc29a2 Mon Sep 17 00:00:00 2001
From: Dewey Dunnington <dewey@fishandwhistle.net>
Date: Tue, 2 Aug 2022 11:44:43 -0300
Subject: [PATCH 1/2] explicit stop producing before return

---
 r/src/compute-exec.cpp | 1 +
 1 file changed, 1 insertion(+)

diff --git a/r/src/compute-exec.cpp b/r/src/compute-exec.cpp
index 91d646f0a3c..28c18c84b91 100644
--- a/r/src/compute-exec.cpp
+++ b/r/src/compute-exec.cpp
@@ -147,6 +147,7 @@ std::shared_ptr<arrow::Table> ExecPlan_read_table(
         return prepared_plan.second->ToTable();
       });
 
+  prepared_plan.first->StopProducing();
   return ValueOrStop(result);
 }
 

From eb8194d06159fd846064ab572432b4cf4889dc49 Mon Sep 17 00:00:00 2001
From: Dewey Dunnington <dewey@fishandwhistle.net>
Date: Wed, 3 Aug 2022 10:05:37 -0300
Subject: [PATCH 2/2] Update r/src/compute-exec.cpp

Co-authored-by: Antoine Pitrou <pitrou@free.fr>
---
 r/src/compute-exec.cpp | 1 +
 1 file changed, 1 insertion(+)

diff --git a/r/src/compute-exec.cpp b/r/src/compute-exec.cpp
index 28c18c84b91..889a79aff92 100644
--- a/r/src/compute-exec.cpp
+++ b/r/src/compute-exec.cpp
@@ -148,6 +148,7 @@ std::shared_ptr<arrow::Table> ExecPlan_read_table(
       });
 
   prepared_plan.first->StopProducing();
+  StopIfNotOk(prepared_plan.first->finished().status());
   return ValueOrStop(result);
 }