All pull requests

Pull requests

• feat(checkpoints): label checkpoint acks and failed epochs per sink

  #184·kquintal opened Nov 5, 2026Contributor·

  ·

• fix(clickhouse): emit source pages in sort-key order

  #183·jeffling opened Nov 4, 2026Contributor·

  ·

• Enable Maestro reviews for org-member PRs

  #182·paymog opened Nov 4, 2026Contributor·1 task done·

  ·

• fix(kafka): read AZ from AVAILABILITY_ZONE before falling back to IMDS

  #179·goldsky-maestro[bot] opened Nov 3, 2026Bot·

  ·
  

• feat: In-Memory Tables

  #167·sap1ens opened Oct 23, 2026Contributor·

  ·

• feat(telemetry): correct starved for task-decoupled operators, add sink starved and empty batches

  #160·kashive opened Oct 8, 2026Contributor·4/4·

  ·
  5

• fix(sinks): write nested decimal_arb values exactly to ClickHouse, Kafka (Avro/JSON), webhook and Postgres

  #158·rafadaguiar opened Oct 7, 2026Contributor·

  ·
  17

• fix(streamling-common): macOS needs the vendored OpenSSL too

  #144·chunxi opened Sep 29, 2026Contributor·

  ·
  6

• fix(hybrid): null-fill nullable Kafka fields absent from the ClickHouse table

  #138·goldsky-maestro[bot] opened Sep 24, 2026Bot·

  ·
  21

  

• feat(telemetry): per-node flow metrics for idleness and backpressure

  #133·rafadaguiar opened Sep 14, 2026Contributor·

  ·
  4

• fix(core): name the available columns when a partition key is missing

  #132·rafadaguiar opened Sep 14, 2026Contributor·

  ·
  3

• fix(connectors): stop a slow Kafka sink from failing the pipeline

  #131·rafadaguiar opened Sep 14, 2026Contributor·

  ·
  6

• feat(connectors): Kafka producer statistics and a producer config escape hatch

  #130·rafadaguiar opened Sep 14, 2026Contributor·

  ·
  9

• fix(connectors): give each Kafka sink write stream its own producer

  #129·goldsky-maestro[bot] opened Sep 12, 2026Bot·

  ·
  

• fix(connectors): honor projection in the ClickHouse scan; harden hybrid alignment

  #128·rafadaguiar opened Sep 9, 2026Contributor·

  ·
  6

• fix: keep checkpoint receives off Tokio workers

  #123·rafadaguiar opened Sep 4, 2026Contributor·

  ·
  1

• feat(telemetry): attribute node_wait{state="blocked"} per downstream edge

  #122·kashive opened Sep 4, 2026Contributor·3/4·

  ·
  17

• feat(telemetry): emit node_wait{state="starved"} and dual-emit elapsed_compute

  #121·kashive opened Sep 4, 2026Contributor·2/4·

  ·
  19

• fix(hybrid): defer phase-state persistence until a covering checkpoint finalizes

  #118·rslowinski opened Sep 3, 2026Contributor·

  ·

• Preview fault isolation: node-attributed errors + tolerant mode (STRM-6479)

  #110·kashive opened Aug 27, 2026Contributor·

  ·

• feat: node-wait state metric (starved / blocked) with downstream attribution

  #38·kashive opened Jun 29, 2026Contributor·4 tasks done·

  ·
  53