risingwavelabs/risingwave · error · SinkError

DeltaLake error

Error message

DeltaLake error: {0}

What it means

A SinkError variant wrapping an anyhow::Error from the deltalake crate. Raised when interactions with a Delta Lake table fail during sink write or commit (I/O, S3/GCS access, schema handling, transaction conflicts).

Solutions

1. Verify the Delta table location and object-store credentials/region in the sink options.
2. Check that the Delta table schema matches the sink's schema.
3. Confirm the target Delta table exists or is creatable with correct permissions.
4. Read the wrapped anyhow message for the underlying deltalake crate error and fix accordingly.

# verify access before sink: aws s3 ls s3://bucket/path --region us-east-1

match err { SinkError::DeltaLake(e) => { log::error!("deltalake: {e:#}"); if is_transient(&e) { retry_with_backoff() } } _ => return Err(err) }

When it happens

Trigger: Writing to or committing a Delta table whose object-store credentials are invalid, table URI is wrong, table schema mismatches the sink schema, or concurrent writers cause transaction conflicts.

Common situations: Missing/expired AWS/GCP credentials on RisingWave nodes, wrong s3:// path or region, Delta table altered externally, unsupported deltalake crate version/table feature.

Related errors

• Can't create deltalake sink write result from empty data!
• failed to write items to DynamoDB sink
• Kinesis error
• LanceDB error
• only append-only delta lake sink is supported

AI-assisted analysis of risingwavelabs/risingwave@6469eb736d (2026-09-11). Data as JSON: /api/errors/a98847f32bf96f81. Report an issue: GitHub.

Appendix: source

Thrown at src/connector/src/sink/mod.rs:1162

        #[source]
        #[backtrace]
        anyhow::Error,
    ),
    #[error("Google Pub/Sub error: {0}")]
    GooglePubSub(
        #[source]
        #[backtrace]
        anyhow::Error,
    ),
    #[error("Doris/Starrocks connect error: {0}")]
    DorisStarrocksConnect(
        #[source]
        #[backtrace]
        anyhow::Error,
    ),
    #[error("Doris error: {0}")]
    Doris(String),
    #[error("DeltaLake error: {0}")]
    DeltaLake(
        #[source]
        #[backtrace]
        anyhow::Error,
    ),
    #[error("LanceDB error: {0}")]
    LanceDb(
        #[source]
        #[backtrace]
        anyhow::Error,
    ),
    #[error("ElasticSearch/OpenSearch error: {0}")]
    ElasticSearchOpenSearch(
        #[source]
        #[backtrace]
        anyhow::Error,
    ),
    #[error("Starrocks error: {0}")]

View on GitHub (pinned to 6469eb736d)