{"record":{"id":"a98847f32bf96f81","repo":"risingwavelabs/risingwave","slug":"deltalake-error-0","errorCode":null,"errorMessage":"DeltaLake error: {0}","messagePattern":"DeltaLake error: (.+?)","errorType":"exception","errorClass":"SinkError","httpStatus":null,"severity":"error","filePath":"src/connector/src/sink/mod.rs","lineNumber":1162,"sourceCode":"        #[source]\n        #[backtrace]\n        anyhow::Error,\n    ),\n    #[error(\"Google Pub/Sub error: {0}\")]\n    GooglePubSub(\n        #[source]\n        #[backtrace]\n        anyhow::Error,\n    ),\n    #[error(\"Doris/Starrocks connect error: {0}\")]\n    DorisStarrocksConnect(\n        #[source]\n        #[backtrace]\n        anyhow::Error,\n    ),\n    #[error(\"Doris error: {0}\")]\n    Doris(String),\n    #[error(\"DeltaLake error: {0}\")]\n    DeltaLake(\n        #[source]\n        #[backtrace]\n        anyhow::Error,\n    ),\n    #[error(\"LanceDB error: {0}\")]\n    LanceDb(\n        #[source]\n        #[backtrace]\n        anyhow::Error,\n    ),\n    #[error(\"ElasticSearch/OpenSearch error: {0}\")]\n    ElasticSearchOpenSearch(\n        #[source]\n        #[backtrace]\n        anyhow::Error,\n    ),\n    #[error(\"Starrocks error: {0}\")]","sourceCodeStart":1144,"sourceCodeEnd":1180,"githubUrl":"https://github.com/risingwavelabs/risingwave/blob/6469eb736d691e8e9b8a419a57edd6429ca77417/src/connector/src/sink/mod.rs#L1144-L1180","documentation":"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).","triggerScenarios":"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.","commonSituations":"Missing/expired AWS/GCP credentials on RisingWave nodes, wrong s3:// path or region, Delta table altered externally, unsupported deltalake crate version/table feature.","solutions":["Verify the Delta table location and object-store credentials/region in the sink options.","Check that the Delta table schema matches the sink's schema.","Confirm the target Delta table exists or is creatable with correct permissions.","Read the wrapped anyhow message for the underlying deltalake crate error and fix accordingly."],"exampleFix":null,"handlingStrategy":"try-catch","validationCode":"# verify access before sink: aws s3 ls s3://bucket/path --region us-east-1","typeGuard":null,"tryCatchPattern":"match err { SinkError::DeltaLake(e) => { log::error!(\"deltalake: {e:#}\"); if is_transient(&e) { retry_with_backoff() } } _ => return Err(err) }","preventionTips":["Validate object-store credentials and region on the RisingWave nodes","Avoid concurrent uncoordinated writers to the same Delta table","Test table URI with delta-rs/deltalake CLI before creating the sink"],"tags":["sink","deltalake","object-store","aws"],"backgroundTag":"upstream-api-error","analyzedSha":"6469eb736d691e8e9b8a419a57edd6429ca77417","analyzedAt":"2026-09-11T21:06:21.487Z","contentChangedAt":"2026-09-11T21:06:21.487Z","schemaVersion":2},"datasetVersion":"2026-09-23T08:17:48.524Z"}