diff --git a/r/R/query-engine.R b/r/R/query-engine.R index 08cfddb21e6a8..b2fdfd09ef481 100644 --- a/r/R/query-engine.R +++ b/r/R/query-engine.R @@ -226,9 +226,7 @@ ExecPlan <- R6Class("ExecPlan", # TODO(ARROW-16628): handle limit in ExecNode slice_size <- node$extras$head %||% node$extras$tail if (!is.null(slice_size)) { - out_head <- head(out, slice_size) - out$Close() - out <- out_head + out <- head(out, slice_size) } } else if (!is.null(node$extras$tail)) { # TODO(ARROW-16630): proper BottomK support