SQL SQL In Depth
0%
case fanout-bug analytics pre-aggregation

Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug

7 min read Module 2.1: Grouping, Aggregations & Multi-Dimensional Rollups Updated Oct 26, 2026
📄 Cheat Sheet
Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug — Database Systems & SQL Architecture Lecture
CMU Database Group (Andy Pavlo) Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug — Database Systems & SQL Architecture Lecture Watch on YouTube ↗

Builds first-principles mastery of Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug with concrete query execution trees, storage page layouts, and production tuning trade-offs.

0:00 / 4:27

1. First-Principles Mental Model & Relational Mechanics

Every SQL statement in Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug compiles down to a deterministic tree of relational algebra operators acting on physical pages in the buffer pool. At the logical layer, Tracing an executive dashboard incident where joining orders to both order_items and shipments inflated reported revenue by 310%. Rather than mutating global variables imperatively, declarative SQL specifies the mathematical properties of the desired output relation while delegating physical access path selection to the cost-based query optimizer.

When the database engine processes case-analytics-double-counting-bug within Grouping, Aggregations & Multi-Dimensional Rollups, it enforces strict invariants over tuple domains, attribute visibility, and I/O page budgets. Understanding the boundary between logical relational semantics (what rows qualify) and physical execution (whether the engine performs a sequential heap scan, a B+Tree range seek, or an in-memory hash probe) is the defining skill of a Staff Database Engineer.

Formal Relational & Cost Invariant — Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug

Let relation RR contain NN tuples stored across BB physical 8KB pages (B≈⌈N/tuples_per_page⌉B \approx \lceil N / \text{tuples\_per\_page} \rceil). Evaluating Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug maintains the relational closure and I/O cost bound:

CostI/O(R)=Bseq⋅cseq+log⁡F(N)⋅crandom,σθ(πA(R))⊆Dom(A)\text{Cost}_{\text{I/O}}(R) = B_{\text{seq}} \cdot c_{\text{seq}} + \log_{F}(N) \cdot c_{\text{random}}, \quad \sigma_{\theta}(\pi_{A}(R)) \subseteq \text{Dom}(A)

Where F≈250–500F \approx 250\text{--}500 is the B+Tree page fanout, σθ\sigma_{\theta} denotes Three-Valued Logic predicate selection over fanout-bug, and πA\pi_{A} projects the target attribute schema without violating domain constraints.

2. Database Table Schema, Execution Pipeline & Visual Architecture

Tracing how Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug flows through the parser, catalog binder, cost-based optimizer, and physical executor reveals exactly where latency and cardinality bugs originate:

  • Stage 1 — Lexical Parsing & Catalog Binding (fanout-bug): The SQL parser builds an Abstract Syntax Tree (AST) and resolves every relation, column identifier, and data type against system catalog tables (such as pg_class, pg_attribute, or sqlite_master).
  • Stage 2 — Logical Rewrite & Algebraic Simplification (analytics): The planner normalizes predicates, pushes selective filters as close to the storage scan as possible, and verifies whether Three-Valued NULL semantics permit subquery unnesting or join elimination.
  • Stage 3 — Cost Estimation & Physical Operator Selection (pre-aggregation): Using histogram boundaries, Most Common Values (MCV), and Number of Distinct Values (NDV), the optimizer selects the minimum-cost physical plan and streams tuples through the execution pipeline.
Production Case Study: Diagnosing a 3x Revenue Over... — Partitioned Table & Sliding Window Frame Module M04 · PARTITION BY dept_id ORDER BY salary_usd DESC · Frame Overlay (fanout-bug) TABLE employees (Partitioned Tuple Stream) PK emp_id dept_id name salary_usd RANK / SUM OVER 2 2 (Storage) Vikramaditya $255,000 #1 · $255k 4 2 (Storage) Mateo Silva $215,000 #2 · $470k [CURRENT ROW] 5 2 (Storage) Aisha Patel $198,000 #3 · $668k 3 3 (Planner) Hannah L. $250,000 #1 · $250k (New Partition) WINDOW FRAME INVARIANTS • Preserves all N input tuples • Frame: UNBOUNDED PRECEDING AND CURRENT ROW • Peer ties handled by ROWS vs RANGE vs GROUPS • Evaluated at Step 5 (pre-SELECT)
flowchart LR A["1. FROM / JOIN (fanout-bug)"] --> B["2. WHERE / 3VL Filter (analytics)"] B --> C["3. GROUP BY / WINDOW OVER"] C --> D["4. SELECT Projection & ORDER BY (pre-aggregation)"]

3. Interactive Table-Level & Storage Engine Simulator

Use the interactive simulator below to step through Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug at the tuple and page level. Observe how input rows, intermediate filter/join states, NULL badges, and physical page reads evolve at each step:

1-to-N-to-M Join Fanout & Chasm Trap Double-Counting Visualizer
Fanout Multiplication

Observe how joining Orders (1) to OrderItems (N) and Payments (M) multiplies rows by N×M and inflates SUM(order_total), then fix it with pre-aggregated CTEs.

Step 1 / 7
Custom Input:
Timeline

Invariant & State

Relation initialized with 5 tuples across schema (order_id, order_total, item_row, payment_row, running_sum_total) — preset: Naive Multi-Branch Join (3×2 Fanout Inflates Revenue 300%).
📊 Live Magnitude & Pointer Stage — 1-to-N-to-M Join Fanout & Chasm Trap Double-Counting Visualizer Active Pivot Match/Sorted
Tuple # 501:it… [0] 501:it… [1] 501:it… [2] 502:it… [3] 502:it… [4]
📋 1-to-N-to-M Join Fanout & Chasm Trap Double-Counting Visualizer — Initial Relation State 5 row(s)
order_idorder_totalitem_rowpayment_rowrunning_sum_totalState
501100.00</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">item #1 (kbd)</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">pay #1 (card)</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">100.00CURSOR START
501100.00</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">item #2 (mouse)</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">pay #1 (card)</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">200.00 (INFLATED!)
501100.00</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">item #3 (dock)</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">pay #1 (card)</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">300.00 (INFLATED!)
502250.00</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">item #1 (monitor)</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">pay #1 (wire)</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">550.00
502250.00</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">item #1 (monitor)</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">pay #2 (credit)</td><td style="padding:5px 8px;border-bottom:1px solid var(--border-subtle,#1f1f23);font-size:11.5px;font-family:var(--font-mono,monospace);">800.00 (INFLATED!)
[0]501:item #1 (kbd)Tuple #0
[1]501:item #2 (mouse)
[2]501:item #3 (dock)
[3]502:item #1 (monitor)
[4]502:item #1 (monitor)
Input Tuples
5
Columns
5
Preset Mode
bug
Pipeline Stage
1. Initial Scan
[Step 1] Initialized 1-to-N-to-M Join Fanout & Chasm Trap Double-Counting Visualizer (Naive Multi-Branch Join (3×2 Fanout Inflates Revenue 300%)) with 5 base rows.

4. Live WASM SQL Lab, Clause-by-Clause Visualizer & Automated Test Checker

Execute, edit, and test the production SQL query below directly in your browser using the embedded WebAssembly SQLite 3 engine. Click ▶ Run Query to execute, 🔍 Step Clauses to inspect the live intermediate table after FROM/JOIN, WHERE, GROUP BY, HAVING, WINDOW, SELECT, and ORDER BY, or ✓ Check SQL Tests to run automated relational assertions against the reference result:

SQL · WASM17 lines
-- Dataset: ecommerce | Conditional Aggregation with FILTER (WHERE ...) & Country Rollups
SELECT
  c.country,
  COUNT(DISTINCT c.customer_id) AS total_customers,
  COUNT(o.order_id) AS total_orders,
  COUNT(o.order_id) FILTER (WHERE o.status = 'completed') AS completed_orders,
  COUNT(o.order_id) FILTER (WHERE o.status IN ('cancelled', 'refunded')) AS reversed_orders,
  ROUND(
    COALESCE(SUM(o.total_cents) FILTER (WHERE o.status = 'completed'), 0) / 100.0,
    2
  ) AS net_settled_revenue_usd
FROM customers AS c
LEFT JOIN orders AS o
  ON o.customer_id = c.customer_id
GROUP BY c.country
HAVING COUNT(o.order_id) >= 1
ORDER BY net_settled_revenue_usd DESC;

5. Cross-Engine Dialect & Cost Comparison Matrix

While the SQL ISO standard defines the logical behavior of Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug, production storage engines differ in how they execute, lock, and index the underlying tuples:

Database Engine Primary Storage & Access Mechanism I/O & CPU Complexity Production Caveat for Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug
PostgreSQL 17 Heap Tuple Store (ctid) + B-Tree / GIN / BRIN + MVCC (xmin/xmax) O(log⁡BN)O(\log_B N) seek / O(N)O(N) scan Requires ANALYZE statistics and Visibility Map bits for Index-Only Scans.
SQLite 3.46 (WASM) B+Tree Table (rowid clustered) + Covering Secondary B-Trees O(log⁡BN)O(\log_B N) B+Tree traversal Runs in-process with zero network RTT; inspect EXPLAIN QUERY PLAN for USE TEMP B-TREE.
MySQL 8.4 (InnoDB) Clustered Primary Key B+Tree + Undo Log Rollback Segments O(log⁡BN)O(\log_B N) PK / 2×O(log⁡BN)2 \times O(\log_B N) Secondary Secondary indexes store the Primary Key value; wide PKs amplify secondary index footprint.
DuckDB / ClickHouse Columnar Vectorized Chunks + Zone Maps (Min/Max Skipping) O(N/SIMD_Width)O(N / \text{SIMD\_Width}) vectorized scan Excels at wide analytical scans and aggregations; avoid single-row OLTP point mutations.

6. Under the Hood: Storage & Execution Engine Implementation (C++20)

To truly understand how a database engine executes Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug without hand-waving, examine the C++20 storage kernel operator below. It models how the execution engine iterates over pinned buffer pool pages, evaluates tuple predicates, and tracks page I/O statistics:

C++2032 lines
#include <iostream>
#include <vector>
#include <cstdint>
#include <string>
#include <algorithm>

// Database Engine Kernel Operator: Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug
struct TuplePageStats {
    uint64_t tuples_examined;
    uint64_t tuples_emitted;
    uint64_t pages_pinned;
};

inline TuplePageStats eval_case_analytics_double_counti(const std::vector<int64_t>& keys, int64_t predicate_bound) noexcept {
    TuplePageStats stats{0, 0, (keys.size() + 127) / 128};
    for (int64_t k : keys) {
        ++stats.tuples_examined;
        if (k >= predicate_bound) {
            ++stats.tuples_emitted;
        }
    }
    return stats;
}

int main() {
    std::vector<int64_t> relation = {10, 25, 40, 55, 70, 85, 100, 115};
    auto res = eval_case_analytics_double_counti(relation, 50);
    std::cout << "[Engine Operator: case-analytics-double-counting-bug] examined=" << res.tuples_examined
              << " emitted=" << res.tuples_emitted
              << " pages=" << res.pages_pinned << "\n";
    return 0;
}

7. Production Failure Modes, Anti-Patterns & Staff Tuning Checklist

Production Pitfall & SEV-1 Outage Pattern

The most common production failure in Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug occurs when a query passes functional unit tests on a 50-row local fixture but degrades into an O(N2)O(N^2) loop, an unindexed full-table scan, or a silent NULL data-drop once table cardinality crosses 10710^7 rows. Always verify both NULL boundary rows and physical buffer reads before deploying to production.

  • Verify Execution Plans Early: Never guess what the planner will do—run EXPLAIN QUERY PLAN (SQLite) or EXPLAIN (ANALYZE, BUFFERS) (PostgreSQL) and confirm that estimated row counts match actual row counts within 2×2\times.
  • Guard Against Three-Valued NULL Traps: Audit every NOT IN, outer-join WHERE filter, and aggregate AVG/COUNT(col) expression for nullable columns; prefer NOT EXISTS and explicit COALESCE defaults.
  • Keep Predicates SARGable: Never wrap an indexed column in a function, arithmetic expression, or implicit type cast on the left-hand side of a comparison operator.
  • Bound Memory & Lock Scope: Ensure sorting, hashing, and batch mutations operate within bounded memory budgets (work_mem) and hold row/table locks for the shortest possible duration.
Check yourself Question 1 of 4
Concept Check Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug — Core Relational Invariant recall

Which statement accurately characterizes the primary mechanism and guarantee of Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug?

Guided SQL & Database Engine Practice · Browser WASM Workbench 3 Guided Steps + Progressive Hints

Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug — Guided SQL & Engine Lab

Tracing an executive dashboard incident where joining orders to both order_items and shipments inflated reported revenue by 310%.

⏱ Target Time: O(N) scan / O(log_B N) indexed 💾 Auxiliary Space: O(1) streaming tuple state 🧭 Pattern: Grouping, Aggregations & Multi-Dimensional Rollups
01 Phase 1 · Tuple State & Boundaries
Initialize Tuple Scan State (eval_case_analytics_double_counti)
Allocate the operator state structure for Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug and establish zero-row boundary invariants.
Replace TODO (Step 1) inside eval_case_analytics_double_counti in src/main.cpp by initializing ExecutionResult out{}; and iterating over table.
💡 Progressive Hint (Step 1)
ExecutionResult out{};
for (const auto& row : table) {
  ++out.rows_scanned;
02 Phase 2 · Three-Valued Logic & Predicate Evaluation
Evaluate 3VL NULL Guard & Predicate Filter
In SQL, NULL comparisons evaluate to UNKNOWN and must be excluded before aggregating.
Implement TODO (Step 2) in src/main.cpp to check !row.is_null && row.metric_cents >= min_cents.
💡 Progressive Hint (Step 2)
if (!row.is_null && row.metric_cents >= min_cents) {
  ++out.rows_matched;
  out.sum_cents += row.metric_cents;
}
03 Phase 3 · Aggregate Projection & Verification
Return Projected Tuple Summary & Pass Unit Assertions
Verify exact integer-cent accumulation and row counts across edge cases.
Complete TODO (Step 3) in src/main.cpp by returning out; and clicking Run & Test.
💡 Progressive Hint (Step 3)
return out;

Key Takeaways

Production Case Study: Diagnosing a 3x Revenue Over-Reporting Fanout Bug (case-analytics-double-counting-bug): Tracing an executive dashboard incident where joining orders to both order_items and shipments inflated reported revenue by 310%.
Always separate logical SQL semantics (FROM -> WHERE -> GROUP BY -> HAVING -> WINDOW -> SELECT -> ORDER BY -> LIMIT) from the physical execution plan chosen by the cost-based optimizer.
Audit every predicate and join condition for Three-Valued Logic (NULL -> UNKNOWN) edge cases and verify SARGability so B+Tree indexes can perform O(log_B N) range seeks.
Use EXPLAIN QUERY PLAN / EXPLAIN (ANALYZE, BUFFERS) to inspect physical scan operators, join algorithms, and temporary sort/hash spills before shipping queries to production.
Was this lesson helpful? Spot an issue or have a suggestion? Let us know on GitHub.
Report an issue