All pull requests

Pull requests

• [kafka] Stream JSON Produce value conversion

  #4906·zephyr45 opened Oct 27, 2026·1 task done·

  ·
  1

• [server] Support adding nested fields to ROW columns

  #4905·raoluSmile opened Oct 27, 2026·

  ·

• [client] Unify cluster inspection in DescribeCluster

  #4901·swuferhong opened Oct 27, 2026Contributor·

  ·
  1

• [docs] Document Kafka produce delivery guarantees

  #4899·dao-jun opened Oct 26, 2026Member·

  ·

• [rpc] Gate channel reads on RequestChannel registration

  #4898·dao-jun opened Oct 26, 2026Member·2 tasks·

  ·

• [kafka] Wire Kafka channels into RequestChannel backpressure

  #4897·dao-jun opened Oct 26, 2026Member·2 tasks·

  ·

• [kafka] Add request metrics with per-table Produce breakdown

  #4896·gyang94 opened Oct 26, 2026Contributor·

  ·

• [helm] Publish each listener's advertised address as a pod env var

  #4895·morazow opened Oct 26, 2026Contributor·

  ·
  1

• [rust] Lookup requests are not drained when batch timeout is zero

  #4893·slfan1989 opened Oct 26, 2026Contributor·

  ·
  1

• [server] Retry kv snapshot lease metadata file writes

  #4892·morazow opened Oct 26, 2026Contributor·

  ·
  1

  1

• [kafka] Prevent Kafka endpoints on coordinator servers

  #4890·zephyr45 opened Oct 26, 2026·1 of 2 tasks·

  ·
  1

• [flink] Add $partitions virtual table

  #4888·fhan688 opened Oct 26, 2026Contributor·

  ·

• [rust] Add reusable UnionRead source boundaries

  #4887·naivedogger opened Oct 26, 2026Contributor·

  ·
  1

  1

• [rpc] Avoid retaining failed connections in the connection pool

  #4884·beryllw opened Oct 26, 2026Contributor·1 task done·

  ·
  1

• [client] Prune Arrow buffers before client-side decompression.

  #4883·loserwang1024 opened Oct 26, 2026Contributor·

  ·
  1

  4

• [rust] Fix projection of remote logs with older schemas

  #4881·spoon-lz opened Oct 26, 2026Contributor·

  ·
  1

• [log] Use the injected clock for writer expiration

  #4879·fxbing opened Oct 26, 2026Contributor·1 of 2 tasks·

  ·
  1

• [c++] Add poll-based async lookups

  #4877·pbanakar opened Oct 26, 2026Contributor·

  ·
  1

  1

• [Doc] Add client bounded scan APIs doc

  #4870·yangshangqing95 opened Oct 25, 2026Contributor·

  ·

• [server] Move leader during reassignment when old leader stays

  #4869·morazow opened Oct 25, 2026Contributor·

  ·
  1

  3

• [elixir] Refactor Fluss.Admin module to use keyword opts

  #4868·nicolazar opened Oct 25, 2026Contributor·

  ·
  1

• [rust] Share KV value decoding between lookup and batch scanner

  #4858·ump45nose opened Oct 24, 2026·1 of 2 tasks·

  ·
  1

• [rpc] Isolate internal listener resources from client backpressure

  #4857·platinumhamburg opened Oct 24, 2026Contributor·

  ·
  1

• [kv] Add TS-level RocksDB cache and read execution metrics

  #4855·platinumhamburg opened Oct 24, 2026Contributor·

  ·
  1

• [docs] Document the Spark tiering service

  #4851·Yohahaha opened Oct 24, 2026Contributor·1 task done·

  ·
  1

  1