Hi @Retired_mod ,

I am using DLT to fetch data from PUBSUB streaming, issue is not related to the checkpoint as DLT automatically maintains all the checkpoints or invalid disk cache as I restart the DLT pipeline that creates a new cluster every time. Also, I have checked and found no schema changes in my data.

I am running the same code on normal cluster with PUBSUB streaming and it's working fine there the issue is only when I am running it through DLT.