diff --git a/dask_sql/physical/rel/logical/limit.py b/dask_sql/physical/rel/logical/limit.py index 468ac6f0d..a6f6f8c1c 100644 --- a/dask_sql/physical/rel/logical/limit.py +++ b/dask_sql/physical/rel/logical/limit.py @@ -58,7 +58,6 @@ def _apply_offset(self, df: dd.DataFrame, offset: int, end: int) -> dd.DataFrame we need to pass the partition number to the selection function, which is not possible with normal "map_partitions". """ - df = df.persist() if not offset: # We do a (hopefully) very quick check: if the first partition # is already enough, we will just use this