apache/iceberg · error · UnsupportedOperationException

doesn't implement fromSnapshotExclusive

Error message

%s doesn't implement fromSnapshotExclusive

What it means

Default-interface guard on IncrementalScan: thrown only when the concrete scan implementation did not override fromSnapshotExclusive, so setting an exclusive start snapshot is unsupported for that class. The %s names the offending runtime class; it is a capability gap, not an input problem.

Solutions

1. Use a scan implementation that supports incremental scans with exclusive start bounds
2. Catch UnsupportedOperationException and degrade to a non-incremental scan
3. Override fromSnapshotExclusive in the custom scan implementation

When it happens

Trigger: Thrown at api/src/main/java/org/apache/iceberg/IncrementalScan.java:74 when the library encounters an invalid state.

Common situations: See trigger scenarios.

AI-assisted analysis of apache/iceberg@86d9c8fc54 (2026-09-12). Data as JSON: /api/errors/b7608643a54670f0. Report an issue: GitHub.

Appendix: source

Thrown at api/src/main/java/org/apache/iceberg/IncrementalScan.java:74

   *
   * @param fromSnapshotId the start snapshot ID (exclusive)
   * @return this for method chaining
   * @throws IllegalArgumentException if the start snapshot is not an ancestor of the end snapshot
   */
  ThisT fromSnapshotExclusive(long fromSnapshotId);

  /**
   * Instructs this scan to look for changes starting from a particular snapshot (exclusive).
   *
   * <p>If the start snapshot is not configured, it defaults to the oldest ancestor of the end
   * snapshot (inclusive).
   *
   * @param ref the start ref name that points to a particular snapshot ID (exclusive)
   * @return this for method chaining
   * @throws IllegalArgumentException if the start snapshot is not an ancestor of the end snapshot
   */
  default ThisT fromSnapshotExclusive(String ref) {
    throw new UnsupportedOperationException(
        this.getClass().getName() + " doesn't implement fromSnapshotExclusive");
  }

  /**
   * Instructs this scan to look for changes up to a particular snapshot (inclusive).
   *
   * <p>If the end snapshot is not configured, it defaults to the current table snapshot
   * (inclusive).
   *
   * @param toSnapshotId the end snapshot ID (inclusive)
   * @return this for method chaining
   */
  ThisT toSnapshot(long toSnapshotId);

  /**
   * Instructs this scan to look for changes up to a particular snapshot ref (inclusive).
   *
   * <p>If the end snapshot is not configured, it defaults to the current table snapshot

View on GitHub (pinned to 86d9c8fc54)