Resolved! File not found error. Does OPTIMIZE deletes initial versions of the delta table?
df = (spark.readStream.format("delta")\ .option("readChangeFeed", "true")\ .option("startingVersion", 1)\ .table("CatalogName.SchemaName.TableName") )display(df)A file referenced in the transaction l...
- 1161 Views
- 1 replies
- 2 kudos
Latest Reply
Had you run vacuum on the table? Vacuum can clean up data files marked for removal and are older than retention period.Optimize compacts files and marks the small files for removal, but does not physically remove the data files
- 2 kudos