Zouxxyy opened a new pull request, #7831:
URL: https://github.com/apache/paimon/pull/7831

   ### Purpose
   
   Implement `PaimonBatchWrite.abort()` to clean up uncommitted data files when 
a Spark write is aborted, replacing the previous `// TODO clean uncommitted 
files` placeholder.
   
   A `commitStarted` flag is added to skip abort cleanup if commit has already 
begun, preventing cleanup of already-committed data.
   
   ### Tests
   
   Added two integration tests in `SparkWriteITCase`:
   - `Paimon Write: abort cleans uncommitted files` — verifies abort removes 
written data files and no snapshot is created
   - `Paimon Write: abort skips cleanup after commit starts` — verifies abort 
is a no-op after commit has started, committed data remains intact


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to