influxdata/influxdb · error · Error

object store error

Error message

object store error: {0}

What it means

Error::ObjectStoreError in influxdb3_wal wraps ::object_store::Error (via #[from]) and is reported as "object store error". It surfaces failures interacting with the configured object store (local filesystem, S3, GCS, Azure) used by the WAL for persistence, e.g. the real-time data flush path.

Solutions

1. Inspect the inner object_store::Error for source (S3/GCS/Azure/local) and fix the specific cause (credentials, bucket name, network)
2. Verify object store configuration (endpoint, region, credentials) before restart
3. Retry on transient errors (throttling/network) with backoff; treat NotFound as missing data rather than a crash

// pre-flight: verify object store reachable
store.head(&object_store::path::Path::from("healthcheck")).await?;

match result {
    Ok(v) => v,
    Err(Error::ObjectStoreError(os_err)) if is_retryable(&os_err) => { retry_with_backoff(); },
    Err(Error::ObjectStoreError(os_err)) => { log::error!("object store: {}", os_err); return Err(os_err.into()); },
    Err(e) => return Err(e),
}

When it happens

Trigger: Any object_store operation performed by the WAL (put/get/list/delete of WAL snapshots or files) fails and the object_store::Error is converted into this variant — bad credentials, missing bucket, network failure, throttling.

Common situations: Misconfigured bucket/container name, expired or missing cloud credentials, network egress blocked, object store rate limits, object not found during replay.

Related errors

• another process has written to the WAL ahead of this one
• object_store error
• Object store operation failed
• Object store operation failed
• bitcode error

AI-assisted analysis of influxdata/influxdb@06200ef96b (2026-09-19). Data as JSON: /api/errors/bebd65fcb0865431. Report an issue: GitHub.

Appendix: source

Thrown at influxdb3_wal/src/lib.rs:49

use std::{any::Any, num::ParseIntError};
use thiserror::Error;
use tokio::sync::{OwnedSemaphorePermit, oneshot};

#[derive(Debug, Error)]
pub enum Error {
    #[error("wal buffer full with {0} ops")]
    BufferFull(usize),

    #[error("error writing wal file: {0}")]
    WriteError(String),

    #[error("deserialize error: {0}")]
    Serialize(#[from] crate::serialize::Error),

    #[error("join error: {0}")]
    Join(#[from] tokio::task::JoinError),

    #[error("object store error: {0}")]
    ObjectStoreError(#[from] ::object_store::Error),

    #[error("wal is shutdown and not accepting writes")]
    Shutdown,

    #[error("invalid gen1 duration {0}. Must be one of 1m, 5m, 10m")]
    InvalidGen1Duration(String),

    #[error("invalid WAL file path")]
    InvalidWalFilePath,
}

pub type Result<T, E = Error> = std::result::Result<T, E>;

#[async_trait]
pub trait Wal: Debug + Send + Sync + 'static {
    /// Buffer writes ops into the buffer, but returns before the operation is persisted to the WAL.
    async fn write_ops_unconfirmed(&self, op: Vec<WalOp>) -> Result<(), Error>;

View on GitHub (pinned to 06200ef96b)