FAILURE MAP
← Case archive

FA-45321 / Data systems / Open access

A vector UDF ignores result null validity · case 01

A vector UDF ignores result null validity.

Verified by executionVariant 1 · 7 checks per implementationDownload source bundle ↓JSON ↗

ROOT CAUSE

udf-vector-cardinality: A vector UDF ignores result null validity.

VERIFIED REPAIR

Preserve the stated physical representation and operation order: Execute a stipulated vector UDF result contract. For every selected batch, output length must equal selected input length, and output validity must have the same length. A malformed batch emits LENGTH_ERROR and no partial values. Valid output values use their own validity and retain selected input identities.

Unsuccessful approach: Zero filling invents non-null UDF results.

Case contract

Execute a stipulated vector UDF result contract. For every selected batch, output length must equal selected input length, and output validity must have the same length. A malformed batch emits LENGTH_ERROR and no partial values. Valid output values use their own validity and retain selected input identities.

Why this case matters

A bounded deterministic data engine model makes representation and changelog faults reproducible.

1 / The failure

Exit 1
"""Failure Map reference implementation. Python standard library only."""
import json

N = 1
observations = []
def solve(d):
    try:
        out=[]
        for ids,selection,values,valid in d:
            selected=[ids[i] for i in selection]
            if len(values)!=len(selected) or len(valid)!=len(selected):
                out.append('LENGTH_ERROR'); continue
            out.append([[ident,values[i]] for i,ident in enumerate(selected)])
        return out
    except (IndexError, KeyError, ValueError, StopIteration) as exc:
        return {"representation_error": type(exc).__name__}
def check(label, actual, expected):
    observations.append({"check": label, "actual": actual, "expected": expected, "passed": actual == expected})
if N == 1:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [1, 2], [True, True]]]), [[[12, 1], [10, 2]]])
    check('short result', solve([[[10, 11], [0, 1], [1], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [1], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [1, 2], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [1], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
elif N == 2:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [2, 3], [True, True]]]), [[[12, 2], [10, 3]]])
    check('short result', solve([[[10, 11], [0, 1], [2], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [2], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [2, 3], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [2], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
elif N == 3:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [3, 4], [True, True]]]), [[[12, 3], [10, 4]]])
    check('short result', solve([[[10, 11], [0, 1], [3], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [3], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [3, 4], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [3], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
elif N == 4:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [4, 5], [True, True]]]), [[[12, 4], [10, 5]]])
    check('short result', solve([[[10, 11], [0, 1], [4], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [4], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [4, 5], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [4], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
elif N == 5:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [5, 6], [True, True]]]), [[[12, 5], [10, 6]]])
    check('short result', solve([[[10, 11], [0, 1], [5], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [5], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [5, 6], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [5], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
print(json.dumps({"observations": observations, "passed": all(x["passed"] for x in observations)}, ensure_ascii=False))
raise SystemExit(0 if all(x["passed"] for x in observations) else 1)
Boundary fixtureActualExpectedOutcome
selected ids[[[12, 1], [10, 2]]][[[12, 1], [10, 2]]]Passed
short result['LENGTH_ERROR']['LENGTH_ERROR']Passed
long validity['LENGTH_ERROR']['LENGTH_ERROR']Passed
short validity['LENGTH_ERROR']['LENGTH_ERROR']Passed
null output[[[10, 1]]][[[10, None]]]Failed
empty result[[]][[]]Passed
no invocations[][]Passed

SHA-256 / f77333df7aed22939a92c254f325045fbf5353b45866546575da731f32941d0a

2 / The unsuccessful fix

Exit 1
"""Failure Map reference implementation. Python standard library only."""
import json

N = 1
observations = []
def solve(d):
    try:
        out=[]
        for ids,selection,values,valid in d:
            selected=[ids[i] for i in selection]
            if len(values)!=len(selected) or len(valid)!=len(selected):
                out.append('LENGTH_ERROR'); continue
            out.append([[ident,values[i] if valid[i] else 0] for i,ident in enumerate(selected)])
        return out
    except (IndexError, KeyError, ValueError, StopIteration) as exc:
        return {"representation_error": type(exc).__name__}
def check(label, actual, expected):
    observations.append({"check": label, "actual": actual, "expected": expected, "passed": actual == expected})
if N == 1:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [1, 2], [True, True]]]), [[[12, 1], [10, 2]]])
    check('short result', solve([[[10, 11], [0, 1], [1], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [1], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [1, 2], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [1], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
elif N == 2:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [2, 3], [True, True]]]), [[[12, 2], [10, 3]]])
    check('short result', solve([[[10, 11], [0, 1], [2], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [2], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [2, 3], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [2], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
elif N == 3:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [3, 4], [True, True]]]), [[[12, 3], [10, 4]]])
    check('short result', solve([[[10, 11], [0, 1], [3], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [3], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [3, 4], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [3], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
elif N == 4:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [4, 5], [True, True]]]), [[[12, 4], [10, 5]]])
    check('short result', solve([[[10, 11], [0, 1], [4], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [4], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [4, 5], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [4], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
elif N == 5:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [5, 6], [True, True]]]), [[[12, 5], [10, 6]]])
    check('short result', solve([[[10, 11], [0, 1], [5], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [5], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [5, 6], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [5], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
print(json.dumps({"observations": observations, "passed": all(x["passed"] for x in observations)}, ensure_ascii=False))
raise SystemExit(0 if all(x["passed"] for x in observations) else 1)
Boundary fixtureActualExpectedOutcome
selected ids[[[12, 1], [10, 2]]][[[12, 1], [10, 2]]]Passed
short result['LENGTH_ERROR']['LENGTH_ERROR']Passed
long validity['LENGTH_ERROR']['LENGTH_ERROR']Passed
short validity['LENGTH_ERROR']['LENGTH_ERROR']Passed
null output[[[10, 0]]][[[10, None]]]Failed
empty result[[]][[]]Passed
no invocations[][]Passed

SHA-256 / 6665760fc8f13221e50faf37af2aa0b19164664e9853e668a6bb4fa214c68565

3 / The verified repair

Exit 0
"""Failure Map reference implementation. Python standard library only."""
import json

N = 1
observations = []
def solve(d):
    try:
        out=[]
        for ids,selection,values,valid in d:
            selected=[ids[i] for i in selection]
            if len(values)!=len(selected) or len(valid)!=len(selected):
                out.append('LENGTH_ERROR'); continue
            out.append([[ident,values[i] if valid[i] else None] for i,ident in enumerate(selected)])
        return out
    except (IndexError, KeyError, ValueError, StopIteration) as exc:
        return {"representation_error": type(exc).__name__}
def check(label, actual, expected):
    observations.append({"check": label, "actual": actual, "expected": expected, "passed": actual == expected})
if N == 1:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [1, 2], [True, True]]]), [[[12, 1], [10, 2]]])
    check('short result', solve([[[10, 11], [0, 1], [1], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [1], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [1, 2], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [1], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
elif N == 2:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [2, 3], [True, True]]]), [[[12, 2], [10, 3]]])
    check('short result', solve([[[10, 11], [0, 1], [2], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [2], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [2, 3], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [2], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
elif N == 3:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [3, 4], [True, True]]]), [[[12, 3], [10, 4]]])
    check('short result', solve([[[10, 11], [0, 1], [3], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [3], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [3, 4], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [3], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
elif N == 4:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [4, 5], [True, True]]]), [[[12, 4], [10, 5]]])
    check('short result', solve([[[10, 11], [0, 1], [4], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [4], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [4, 5], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [4], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
elif N == 5:
    check('selected ids', solve([[[10, 11, 12], [2, 0], [5, 6], [True, True]]]), [[[12, 5], [10, 6]]])
    check('short result', solve([[[10, 11], [0, 1], [5], [True, True]]]), ['LENGTH_ERROR'])
    check('long validity', solve([[[10], [0], [5], [True, False]]]), ['LENGTH_ERROR'])
    check('short validity', solve([[[10, 11], [0, 1], [5, 6], [True]]]), ['LENGTH_ERROR'])
    check('null output', solve([[[10], [0], [5], [False]]]), [[[10, None]]])
    check('empty result', solve([[[10], [], [], []]]), [[]])
    check('no invocations', solve([]), [])
print(json.dumps({"observations": observations, "passed": all(x["passed"] for x in observations)}, ensure_ascii=False))
raise SystemExit(0 if all(x["passed"] for x in observations) else 1)
Boundary fixtureActualExpectedOutcome
selected ids[[[12, 1], [10, 2]]][[[12, 1], [10, 2]]]Passed
short result['LENGTH_ERROR']['LENGTH_ERROR']Passed
long validity['LENGTH_ERROR']['LENGTH_ERROR']Passed
short validity['LENGTH_ERROR']['LENGTH_ERROR']Passed
null output[[[10, None]]][[[10, None]]]Passed
empty result[[]][[]]Passed
no invocations[][]Passed

SHA-256 / 90f6dd0cb980d8cbf3e353c24205b0be51f5a85ae554b6c02c13b33be8cef471

Verification & scope

Offline stipulated semantics over valid small inputs; no performance, concurrency, or production-engine conformance claim. This reproducer isolates one failure mechanism. Results cover the supplied fixtures. Variants within a family share a test contract and should remain grouped when constructing evaluation splits. Related mechanisms with a shared evaluation_group must also remain together; these controlled models are not independent production incidents.

Observations recorded using Python 3.12.14 at 2026-09-29T14:44:21.042662+00:00.

Case digest / 440e29e3c0cb9de40a5e334dab7f0576f56a5a0270e74346d8a26a2de6bf6d38