influxdata/influxdb · critical · PersisterError

table snapshot persistence task panicked

Error message

table snapshot persistence task panicked: {0}

What it means

PersisterError::TableSnapshotPersistenceTaskFailed indicates that a spawned tokio task responsible for persisting a table snapshot panicked. The JoinError from `tokio::spawn(...).await` is attached as the `#[source]`.

Solutions

1. Read the attached JoinError's panic message to locate the panicking code in snapshot persistence.
2. Fix the underlying panic (usually an unwrap/expect on data that can legitimately be absent).
3. Check memory limits — panics/OOM kills in spawned tasks show up as JoinError.
4. Upgrade influxdb3 if the panic traces to library code.

Example fix

// before: panicking unwrap inside snapshot task
let schema = tables.get(&table_id).unwrap();
// after
let schema = tables.get(&table_id)
    .ok_or_else(|| anyhow!("table {table_id} missing from snapshot"))?;

fn is_snapshot_task_panic(e: &PersisterError) -> bool {
    matches!(e, PersisterError::TableSnapshotPersistenceTaskFailed(_))
}

match persister.persist_snapshot(...).await {
    Err(PersisterError::TableSnapshotPersistenceTaskFailed(join)) => {
        eprintln!("snapshot task panicked: {join}");
        // inspect join.into_panic() downcast to &str/String for the panic message
    }
    Err(e) => return Err(e.into()),
    Ok(v) => v,
}

When it happens

Trigger: Calling a Persister method that spawns a background table-snapshot persistence task (tokio::spawn) and the task panics (e.g. unwrap on None, index out of bounds, assertion inside the task); the JoinError surfaces when awaiting the handle.

Common situations: Panic inside snapshot code due to malformed data or a bug; OOM-triggered aborts in the task; running with a runtime shutdown while tasks are still pending.

Related errors

• snapshot manifest parse task panicked
• start watchdog thread
• Table snapshot persistence task failed
• blocking task join
• column id in series key should be valid

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

Appendix: source

Thrown at influxdb3_write/src/persister.rs:71

    #[error("serde_json error: {0}")]
    SerdeJson(#[from] serde_json::Error),

    #[error("object_store error: {0}")]
    ObjectStore(#[from] object_store::Error),

    #[error("parquet error: {0}")]
    ParquetError(#[from] parquet::errors::ParquetError),

    #[error("tried to serialize a parquet file with no rows")]
    NoRows,

    #[error("parse int error: {0}")]
    ParseInt(#[from] std::num::ParseIntError),

    #[error("unexpected persister error: {0:?}")]
    Unexpected(#[from] anyhow::Error),

    #[error("table snapshot persistence task panicked: {0}")]
    TableSnapshotPersistenceTaskFailed(#[source] tokio::task::JoinError),

    #[error("snapshot manifest parse task panicked: {0}")]
    SnapshotParseTaskFailed(#[source] tokio::task::JoinError),

    #[error("table index error: {0}")]
    TableIndexPathError(#[source] crate::paths::PathError),

    #[error("object meta is missing filename")]
    MissingFilename,

    #[error("failed to parse snapshot sequence number from filename")]
    InvalidSnapshotSequenceNumber,
}

impl From<PersisterError> for DataFusionError {
    fn from(error: PersisterError) -> Self {
        match error {

View on GitHub (pinned to 06200ef96b)