Commits

Breadcrumbs

History for

onmain

User selector

All users

All time

Commit History

Commits on May 22, 2026

• chore: graceful shutdown instead of being stuck on eot error (#3439)

  Show description for 3874eb6
  yhl25

  authored
  3874eb6

  Copy full SHA for 3874eb6

Commits on May 21, 2026

• feat: isb spans for tracing (#3437)

  Show description for c33dd81
  adarsh0728

  authored
  c33dd81

  Copy full SHA for c33dd81

Commits on May 18, 2026

• feat: add spans for tracing (#3397)

  Show description for d8f9522
  

  3 peopleauthored
  d8f9522

  Copy full SHA for d8f9522

Commits on May 14, 2026

• fix: return with rx early when stream mapper is closed (#3431)

  Show description for 3f20f81
  vaibhavtiwari33

  authored
  3f20f81

  Copy full SHA for 3f20f81

Commits on May 13, 2026

• chore: discard duplicates among inflight messages (#3429)

  Show description for 616e8e8
  yhl25

  authored
  616e8e8

  Copy full SHA for 616e8e8

• fix: add monovtx_udf_drop_total metric for MonoVertex map UDF drops (#3427)

  Show description for aa5d73b
  adarsh0728

  authored
  aa5d73b

  Copy full SHA for aa5d73b

Commits on May 11, 2026

• fix: mark JS stream as full until proven otherwise (#3422)

  Show description for 82e480a
  

  vaibhavtiwari33

  and

  vigith

  authored
  82e480a

  Copy full SHA for 82e480a

Commits on May 7, 2026

• fix: race between udf server processing and msg id insertion in map for tracking (#3401)

  Show description for a70baf2
  

  vaibhavtiwari33

  and

  vigith

  authored
  a70baf2

  Copy full SHA for a70baf2

Commits on May 6, 2026

• chore: consider graceful timeout for batch map operations (#3406)

  Show description for 284552f
  

  3 peopleauthored
  284552f

  Copy full SHA for 284552f

• fix: use podman as fallback when docker is not available in numaflow-… (#3407)

  Show description for 85fd8bc
  suryapratap-01

  authored
  85fd8bc

  Copy full SHA for 85fd8bc

Commits on May 5, 2026

• fix: nack messages during token cancellation and discardLatest strategy (#3404)

  Show description for 5e4873d
  

  vaibhavtiwari33

  and

  vigith

  authored
  5e4873d

  Copy full SHA for 5e4873d

Commits on May 4, 2026

• fix: use min event_time across in-flight msgs before publishing idle src wm (#3400)

  Show description for 6b30309
  vaibhavtiwari33

  authored
  6b30309

  Copy full SHA for 6b30309

Commits on May 2, 2026

• feat: add reduce metrics for rust data plane (#3364)

  Show description for aaa5f77
  

  adarsh0728

  and

  vigith

  authored
  aaa5f77

  Copy full SHA for aaa5f77

Commits on Apr 30, 2026

• fix: append parent index information in message ID offset (#3394)

  Show description for ce2ac17
  

  vaibhavtiwari33

  and

  BulkBeing

  authored
  ce2ac17

  Copy full SHA for ce2ac17

Commits on Apr 29, 2026

• fix: Exit with non-zero status on error and log errors when we receive duplicate message sink UDF (#3398)

  Show description for 27e11af
  BulkBeing

  authored
  27e11af

  Copy full SHA for 27e11af

Commits on Apr 22, 2026

• feat: add OTLP export into tracing setup with context propagation helpers (#3385)

  Show description for 4dc4734
  

  adarsh0728

  and

  vigith

  authored
  4dc4734

  Copy full SHA for 4dc4734

Commits on Apr 21, 2026

• refactor: Nack Messages by default to avoid acking failed messages (#3342)

  Show description for 4ffd0b1
  

  yhl25

  and

  vaibhavtiwari33

  authored
  4ffd0b1

  Copy full SHA for 4ffd0b1

Commits on Apr 17, 2026

• chore: components should cancel the token on critical errors (#3381)

  Show description for 7f41342
  yhl25

  authored
  7f41342

  Copy full SHA for 7f41342

• fix: allow token cancellation from streaming_read errors (#3373)

  Show description for f5f4cc4
  

  vaibhavtiwari33

  and

  vigith

  authored
  f5f4cc4

  Copy full SHA for f5f4cc4

• chore: Upgrade to Rust 1.95 (#3375)

  Show description for 052390c
  BulkBeing

  authored
  052390c

  Copy full SHA for 052390c

Commits on Apr 16, 2026

• chore: use correct partition id when multiple topics are used in Kafka source (#3338)

  Show description for a644e55
  

  3 peopleauthored
  a644e55

  Copy full SHA for a644e55

Commits on Apr 15, 2026

• chore: liveness check for udf in mvtx (#3372)

  Show description for 93ac609
  whynowy

  authored
  93ac609

  Copy full SHA for 93ac609

• tests: Watermark tests (#3344)

  Show description for 50d403f
  vaibhavtiwari33

  authored
  50d403f

  Copy full SHA for 50d403f

• chore(deps): bump rand from 0.9.2 to 0.9.3 in /rust (#3363)

  Show description for efffe7b
  dependabot[bot]

  authored
  efffe7b

  Copy full SHA for efffe7b

Commits on Apr 13, 2026

• chore: remove phantom data markers (#3360)

  Show description for c63fdc4
  vaibhavtiwari33

  authored
  c63fdc4

  Copy full SHA for c63fdc4

Commits on Apr 4, 2026

• fix(test): cargo test fails if redis is not running (#3352)

  Show description for 8119090
  vigith

  authored
  8119090

  Copy full SHA for 8119090

• refactor(test): replace loop in #3350 with backoff::Retry (#3351)

  Show description for 27e5c31
  vigith

  authored
  27e5c31

  Copy full SHA for 27e5c31

• fix: replace single sleep before fetching pending count with a timeout (#3350)

  Show description for 24d88d8
  vaibhavtiwari33

  authored
  24d88d8

  Copy full SHA for 24d88d8

Commits on Mar 31, 2026

• feat: http port support for http source (#3341)

  Show description for 1af0d2e
  yhl25

  authored
  1af0d2e

  Copy full SHA for 1af0d2e

Commits on Mar 26, 2026

• feat: Support configuring port for http source (#3335)

  Show description for 45ecac7
  vaibhavtiwari33

  authored
  45ecac7

  Copy full SHA for 45ecac7

Commits on Mar 25, 2026

• refactor: Merge Heartbeat and OT Buckets for Watermark Progression (#3287)

  Show description for 6cbe3a7
  

  yhl25

  and

  vigith

  authored
  6cbe3a7

  Copy full SHA for 6cbe3a7

Commits on Mar 21, 2026

• fix: map stream can ack inflight messages during panic and tests (#3267)

  Show description for f820fc6
  vaibhavtiwari33

  authored
  f820fc6

  Copy full SHA for f820fc6

Commits on Mar 20, 2026

• test: Tests for sink forwarder using simple buffer backed ISBs (#3282)

  Show description for 2550052
  vaibhavtiwari33

  authored
  2550052

  Copy full SHA for 2550052

Commits on Mar 17, 2026

• opex: emit SQS metrics (#3315)

  Show description for 38b0ff8
  

  ayildirim21

  and

  Abdullah Yildirim

  authored
  38b0ff8

  Copy full SHA for 38b0ff8

Commits on Mar 13, 2026

• test: Unit tests for ordered processing (#3303)

  Show description for a485b6d
  vaibhavtiwari33

  authored
  a485b6d

  Copy full SHA for a485b6d