Commits

Branch selector

 master

User selector

All users

All time

Commit History

Commits on Apr 1, 2026

• Introduce worker job controller mode (#1035)

  mwylde

  authored
  bf78428

  Copy full SHA for bf78428

Commits on Mar 30, 2026

• Refactor out common RPC components (#1033)

  mwylde

  authored
  accabc9

  Copy full SHA for accabc9

Commits on Mar 17, 2026

• Make watermark-based file rollover optional, and default to off (#1032)

  mwylde

  authored
  9c9b44e

  Copy full SHA for 9c9b44e

Commits on Mar 16, 2026

• Improve retry mapping logic for Iceberg errors (#1031)

  mwylde

  authored
  c11e94b

  Copy full SHA for c11e94b

Commits on Mar 12, 2026

• Improve Iceberg error mappings (#1029)

  mwylde

  authored
  de35858

  Copy full SHA for de35858

• Address non-idempotent recovery for initiated multiparts (#1027)

  mwylde

  authored
  9ac0f28

  Copy full SHA for 9ac0f28

• Update rollup version to 4.59.0 (#1028)

  mwylde

  authored
  61154b6

  Copy full SHA for 61154b6

Commits on Mar 6, 2026

• Local json compression + optimization for empty encoders (#1021)

  Show description for 3f6e1e2
  QnJ1c2kNCg

  authored
  3f6e1e2

  Copy full SHA for 3f6e1e2

Commits on Mar 5, 2026

• Output full Iceberg catalog error (#1024)

  mwylde

  authored
  c15effc

  Copy full SHA for c15effc

Commits on Feb 25, 2026

• Hold input queues until ready for shutdown (#1020)

  Show description for b53b843
  mwylde

  authored
  b53b843

  Copy full SHA for b53b843

• Add support for Gzip compression for the JSON format on Filesystem connector (V1 and V2) (#1007)

  Show description for 6db4371
  QnJ1c2kNCg

  authored
  6db4371

  Copy full SHA for 6db4371

• Add output format and table format labels to filesystem sink trace events (#1019)

  garvit-gupta

  authored
  ed4ea0e

  Copy full SHA for ed4ea0e

Commits on Feb 19, 2026

• docs: fix broken links in README and CONTRIBUTING (#1018)

  Show description for ec12e8b
  cluster2600

  authored
  ec12e8b

  Copy full SHA for ec12e8b

Commits on Feb 18, 2026

• Fix race condition in bounded queue (#1017)

  mwylde

  authored
  5a31d17

  Copy full SHA for 5a31d17

• Revert "Build `webui/` as part of `cargo build` (#1008)" (#1015)

  Show description for 84589c1
  QnJ1c2kNCg

  authored
  84589c1

  Copy full SHA for 84589c1

• Partial revert of f940d30af308cb02e1b1be2d2939a46406ca694b (#1016)

  Show description for 25ae993
  QnJ1c2kNCg

  authored
  25ae993

  Copy full SHA for 25ae993

• Fix `bytes` calculation in `checkpoint_state` (#1004)

  QnJ1c2kNCg

  authored
  e303ded

  Copy full SHA for e303ded

Commits on Feb 11, 2026

• Update Rust toolchain to 1.93 in CI (#1012)

  QnJ1c2kNCg

  authored
  35e50bc

  Copy full SHA for 35e50bc

Commits on Feb 10, 2026

• Build `webui/` as part of `cargo build` (#1008)

  Show description for a1dd91a
  QnJ1c2kNCg

  authored
  a1dd91a

  Copy full SHA for a1dd91a

• Fix various nitpicking/typos (#1009)

  QnJ1c2kNCg

  authored
  f940d30

  Copy full SHA for f940d30

• Preserve epoch continuity when restarting without state (#1003)

  garvit-gupta

  authored
  4a66502

  Copy full SHA for 4a66502

• Add config to disable persisting deserialization errors to DB (#1011)

  garvit-gupta

  authored
  7cedf21

  Copy full SHA for 7cedf21

• Redact raw values from deserialization error logging (#1010)

  garvit-gupta

  authored
  54990af

  Copy full SHA for 54990af

Commits on Feb 5, 2026

• Remove unsused variable (#1006)

  Show description for 9ed37ac
  QnJ1c2kNCg

  authored
  9ed37ac

  Copy full SHA for 9ed37ac

• Propagate error during hash computation (#1005)

  Show description for 4955411
  QnJ1c2kNCg

  authored
  4955411

  Copy full SHA for 4955411

Commits on Feb 4, 2026

• Cleanup cargo tomls (#1001)

  Show description for 28f0852
  QnJ1c2kNCg

  authored
  28f0852

  Copy full SHA for 28f0852

Commits on Feb 3, 2026

• Improve single-file uploads by not sending contents over the commit rpcs (#997)

  mwylde

  authored
  8f46d60

  Copy full SHA for 8f46d60

• Add retries on failures to fetch/write checkpoints (#1000)

  Show description for 65e9915
  QnJ1c2kNCg

  authored
  65e9915

  Copy full SHA for 65e9915

Commits on Feb 2, 2026

• Fix deserialization error counter increment (#999)

  garvit-gupta

  authored
  0388720

  Copy full SHA for 0388720

Commits on Jan 31, 2026

• Add state migration system for operators (#996)

  mwylde

  authored
  8a87ecc

  Copy full SHA for 8a87ecc

Commits on Jan 22, 2026

• feat: add ignore_state option to pipeline restart (#992)

  garvit-gupta

  authored
  7f5fcd1

  Copy full SHA for 7f5fcd1

Commits on Jan 21, 2026

• Limit number of recovery attempts for task failures (#993)

  mwylde

  authored
  3b4e8ae

  Copy full SHA for 3b4e8ae

Commits on Jan 14, 2026

• Filesystem Sink v2 (#989)

  mwylde

  authored
  9255b77

  Copy full SHA for 9255b77

• Fix tutorial link in README.md (#990)

  Show description for a0095b1
  wshirey

  authored
  a0095b1

  Copy full SHA for a0095b1

• Retry unhandled panics in data flow (#991)

  mwylde

  authored
  15e1d99

  Copy full SHA for 15e1d99