Package io.delta.storage.commit.uccommitcoordinator

Class CommitCompletionUnknownException

Object

Throwable

Exception

io.delta.storage.commit.CommitFailedException

io.delta.storage.commit.uccommitcoordinator.CommitCompletionUnknownException

All Implemented Interfaces:

Serializable

public class CommitCompletionUnknownException
extends CommitFailedException

Raised when UC cannot determine whether the commit at the requested version already landed: the version is at or below the latest commit, but UC retains no row at it (the row was backfilled and cleaned up), so UC cannot tell whether the version holds this caller's own commit or a different writer's.

The client must verify its staged commit against the backfilled <version>.json on the filesystem before rebasing; a content match means the commit already landed and must not be re-committed (otherwise a lost-ACK retry double-commits the data at version+1).

Extends CommitFailedException (retryable + conflict) on purpose: it must be caught by the commit-coordinator retry loop, where the filesystem verification lives.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
CommitCompletionUnknownException(String message)

Method Summary

Methods inherited from class io.delta.storage.commit.CommitFailedException

getConflict, getRetryable

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

CommitCompletionUnknownException

public CommitCompletionUnknownException(String message)