Class CommitFailedException

Object
Throwable
Exception
io.delta.storage.commit.CommitFailedException
All Implemented Interfaces:
Serializable

public class CommitFailedException extends Exception
Exception raised by CommitCoordinatorClient.commit(LogStore, Configuration, TableDescriptor, long, Iterator, UpdatedActions)
  | retryable | conflict  | meaning                                                         |
  |   no      |   no      | something bad happened (e.g. auth failure)                      |
  |   no      |   yes     | permanent transaction conflict (e.g. multi-table commit failed) |
  |   yes     |   no      | transient error (e.g. network hiccup)                           |
  |   yes     |   yes     | physical conflict (allowed to rebase and retry)                 |
  
See Also:
  • Constructor Details

    • CommitFailedException

      public CommitFailedException(boolean retryable, boolean conflict, String message)
    • CommitFailedException

      public CommitFailedException(boolean retryable, boolean conflict, String message, Throwable cause)
  • Method Details

    • getRetryable

      public boolean getRetryable()
    • getConflict

      public boolean getConflict()