Method handle_array_flush

nodedb/src/data/executor/dispatch/array/mutate.rs:73–91

(
        &mut self,
        task: &ExecutionTask,
        array_id: &ArrayId,
        wal_lsn: u64,
    )

    }

    pub(in crate::data::executor) fn handle_array_flush(
        &mut self,
        task: &ExecutionTask,
        array_id: &ArrayId,
        wal_lsn: u64,
    ) -> Response {
        // The Control Plane allocated `wal_lsn` from the central WAL
        // writer; the engine just stamps it as the segment's flush
        // watermark.
        if let Err(e) = self.array_engine.flush(array_id, wal_lsn) {
            return self.response_error(
                task,
                ErrorCode::Internal {
                    detail: format!("array flush: {e}"),
                },
            );
        }
        encode_count_response(self, task, "flushed", 1)
    }

    /// `ArrayOp::DropArray` handler — broadcast on `DROP ARRAY` after
    /// the Control-Plane catalog mutation. Releases the per-core store