[
https://issues.apache.org/jira/browse/SPARK-42353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684501#comment-17684501
]
Apache Spark commented on SPARK-42353:
--------------------------------------
User 'chaoqin-li1123' has created a pull request for this issue:
https://github.com/apache/spark/pull/39897
> Cleanup orphan sst and log files in RocksDB checkpoint directory
> ----------------------------------------------------------------
>
> Key: SPARK-42353
> URL: https://issues.apache.org/jira/browse/SPARK-42353
> Project: Spark
> Issue Type: Bug
> Components: Structured Streaming
> Affects Versions: 3.2.3
> Reporter: Chaoqin Li
> Priority: Major
>
> When RocksDB version.zip file get overwritten (e.g. concurrent task
> execution, task/stage/batch reattempts) or the zip file don't get uploaded
> successfully, the associated sst and log files don't get garbage
> collected.([https://github.com/databricks/runtime/blob/master/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBFileManager.scala|https://github.com/databricks/runtime/blob/master/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBFileManager.scala#L305-L309])
> These files consume storage. We can clean up these SST files during periodic
> state store maintenance. The major concern is that sst files for ongoing
> version also appear to be "orphan" because they are uploaded before zip file,
> we have to be careful not to delete them.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
