topic Re: How to remove checkpoints from DeltaLake table ? in Data Engineering

How to remove checkpoints from DeltaLake table ?

Hunter1604 — Thu, 30 Mar 2023 18:44:11 GMT

How to remove checkpoints from DeltaLake table ?

I see that on my delta table exist a few checkpoints I want to remove the oldest one.

It seems that existing of it is blocking removing the oldest _delta_logs entries

Re: How to remove checkpoints from DeltaLake table ?

Ajay-Pandey — Fri, 31 Mar 2023 09:11:37 GMT

Hi @Pawel Woj ,

If you want to keep your checkpoints X days, you can set delta.checkpointRetentionDuration to X days this way:

spark.sql(f"""
        ALTER TABLE delta.`path`
            SET TBLPROPERTIES (
                delta.checkpointRetentionDuration = 'X days'
            )
        """
)

Re: How to remove checkpoints from DeltaLake table ?

Anonymous — Sat, 01 Apr 2023 02:09:15 GMT

Hi @Pawel Woj

Hope everything is going great.

Just wanted to check in if you were able to resolve your issue. If yes, would you be happy to mark an answer as best so that other members can find the solution more quickly? If not, please tell us so we can help you.

Cheers!

Re: How to remove checkpoints from DeltaLake table ?

Hunter1604 — Mon, 03 Apr 2023 11:31:29 GMT

Hi,

This looks well, thanks - will be testing it.

Re: How to remove checkpoints from DeltaLake table ?

Hunter1604 — Mon, 03 Apr 2023 11:34:54 GMT

Proposed solution looks good, I will be testing it,

but can you tell me why I can't found this param in offical DB documentation ?

I would like to have more infromation about before apply this configuration on prod evn.

Re: How to remove checkpoints from DeltaLake table ?

Ajay-Pandey — Mon, 03 Apr 2023 12:33:42 GMT

Test and let me know if it's working for you.