Read 2026-11-03
numaproj/numaflow: technical due diligence, read from its repository
What Borehole read in numaproj/numaflow's code and history at b3e7c65: its licence, security advisories, releases, review practice, tests, dependencies and operations. Every finding cites the file and line it rests on. The full report also covers the team and asks the questions the code cannot answer.
| Dimension | Rating |
|---|---|
| Architecture & Codebase — including AI provenance | strong |
| Engineering Process & SDLC Maturity | adequate |
| Product & Engineering Maturity | adequate |
| Security & Reliability Posture | adequate |
| Observability & Operations | adequate |
| Fit with the Acquirer | not assessable |
What the repository says
- Releases are cut from another branch than the one surveyed
Architecture & Codebase — including AI provenance
strongrust/numaflow-throttling/src/lib.rs is 4,738 lines, 46× this codebase's median file
adequateThe median source file here is 103 lines. 38 files exceed 1,030 lines, the largest being 4,738. Size is not a defect on its own — some problems genuinely live in one place — but these are where merge conflicts, review fatigue and single-owner knowledge concentrate, and they are the first thing that slows an inheriting engineer down.
rust/numaflow-throttling/src/lib.rs:1 — 4,738 lines (46× median) |
rust/extns/numaflow-sqs/src/source.rs:1 — 3,360 lines (32× median) |
rust/numaflow-core/src/reduce/reducer/unaligned/reducer.rs:1 — 2,583 lines (25× median) |
rust/numaflow-core/src/source.rs:1 — 2,435 lines (23× median) |
rust/numaflow-core/src/metrics/mod.rs:1 — 2,397 lines (23× median) |
Engineering Process & SDLC Maturity
adequate7% of recent commits change more than 2,000 lines
adequate46 of 668 commits in the last 24 months changed over 2,000 lines of code, not counting reformatting, renames, vendored or generated code. A change that size is rarely reviewed line by line. Ask how they were reviewed, and what made them that large.
| 46 commits over 2,000 lines |
Product & Engineering Maturity
adequate2 jobs are each done by more than one library
adequateWithin a single package: UI component kits: material-ui, mui; dates: date-fns, dayjs, moment. Each duplicate is bundle size, two ways of doing the same thing in one codebase, and two upgrade paths to maintain. It is usually the residue of a migration that stopped halfway.
ui/package.json — several libraries per job |
5 files still carry code deprecated more than two years ago
adequate5 files were marked deprecated over two years ago and still are, the oldest since May 2022. A deprecation is a promise to remove. Ask what still depends on these, and whether removing them is scheduled.
pkg/client/informers/externalversions/factory.go — deprecated since May 2022 |
pkg/apis/proto/isb/message.pb.go — deprecated since Jun 2024 |
pkg/apis/proto/daemon/daemon.pb.go — deprecated since Jul 2024 |
pkg/apis/numaflow/v1alpha1/scale.go — deprecated since Aug 2024 |
pkg/apis/proto/mvtxdaemon/mvtxdaemon.pb.go — deprecated since Aug 2024 |
Releases are cut from another branch than the one surveyed
adequateThe newest release, v1.9.0, is not on the branch this survey read. The shipped product may differ from what this report describes. Survey the release branch too.
| tag v1.9.0 |
Security & Reliability Posture
adequate1 Dockerfile runs the application as root
adequateNo USER instruction switches away from root, so the process runs with full privileges inside the container. It is a one-line fix and an ordinary expectation, which is why its absence is worth asking about: it usually says more about whether anyone has reviewed the deployment than about this container specifically.
Dockerfile — runs as root |
The build runs third-party code it does not pin
adequate11 third-party CI actions are referenced by a tag or branch rather than a commit, so they run whatever that tag points to on the day; 2 steps pipe a download straight into a shell. Tags have been moved to malicious commits in real supply-chain attacks, and a piped script is whatever the server returns that minute. Pinning to a commit is the fix, and it is small.
.github/workflows/changelog.yml:20 — action pinned by tag |
.github/workflows/ci.yaml:98 — action pinned by tag |
.github/workflows/ci.yaml:253 — download piped into a shell |
7 of 12 Kubernetes workloads declare no resource limits
adequate7 workload manifests set no CPU or memory limits. One pod that leaks memory or spins can starve everything else on its node, and the scheduler cannot plan capacity for what it cannot see.
config/advanced-install/numaflow-dex-server.yaml — workload with no limits |
config/apps/kafka/kafka-minimal.yaml — workload with no limits |
config/apps/nats/nats.yaml — workload with no limits |
60 locked dependencies have published vulnerabilities, 31 high or critical
adequate60 of 2,352 locked dependencies match 120 published advisories in OSV, 31 of them rated high or critical. A lockfile says which version is installed, not whether the flawed code is reachable from this product, so each needs a look. Most are fixed by an upgrade, and the advisory names the version. None of the high or critical ones is in what the product ships: 1 apply only under a condition the advisory states, which a lockfile cannot settle. This lockfile pins development tools alongside what ships and does not say which is which, so some of these may never reach a user.
rust/Cargo.lock — aws-smithy-json 0.61.9: GHSA-8ffr-xgwf-xj56 (high), fixed in 0.62.7 |
rust/Cargo.lock — openssl 0.10.73: GHSA-8c75-8mhr-p7r9 (high), fixed in 0.10.78 |
rust/Cargo.lock — rustls-webpki 0.101.7: GHSA-82j2-j2ch-gfr8 (high), fixed in 0.103.13 |
Observability & Operations
adequateNo error reporter is wired in
adequateNothing in the service initialises an error reporter (Sentry, Rollbar, Bugsnag, Honeybadger or an APM agent). An exception in production reaches a person only if someone is reading the logs, which usually means a customer reports it first.
| no error reporter initialised |
1 of 3 deployed images carry no version, or `latest`
adequate1 images in the deployment configuration are named without a version or as `latest`. A redeploy can change the software without a commit, a rollback has nothing to roll back to, and nobody can say from the repository what is running.
config/base/numaflow-server/numaflow-server-deployment.yaml:66 — image without a version |
Readiness and liveness probes are identical in 1 of 7 workloads
adequateBoth probes call the same endpoint. When a dependency slows down, the liveness probe fails with the readiness probe, so the platform restarts pods that only needed taking out of rotation, and a partial outage becomes a full one. Liveness should ask whether the process is alive; readiness whether it can serve.
config/apps/nats/nats.yaml — same probe endpoint twice |
10 of 12 deployments run a single replica
adequate10 deployments set `replicas: 1`, and nothing (an autoscaler, a disruption budget) adds more. Every deploy and every node drain is downtime, and the availability the buyer inherits has a ceiling.
config/advanced-install/namespaced-controller-wo-crds.yaml — replicas: 1 |
config/advanced-install/namespaced-numaflow-server.yaml — replicas: 1 |
config/advanced-install/numaflow-server.yaml — replicas: 1 |
Fit with the Acquirer
not assessableNot rated: structurally not assessable from a repository.
Read more, or read your own
The full report on numaproj/numaflow: every dimension, the questions for the room, and the audit log.
Survey a repository: free on public repositories. Private code is read on your own machine by a collector whose source you can read first.