All pull requests

Pull requests

• [trino] Add predicate constraint handling and equality-based partition pruning

  #4689·yangshangqing95 opened Oct 17, 2026Contributor·

  ·

• [kafka] Preserve unknown JSON fields in rescue column

  #4686·gyang94 opened Oct 17, 2026Contributor·

  ·
  1

• [kafka] Support complex JSON values in Produce

  #4684·gyang94 opened Oct 17, 2026Contributor·

  ·
  1

• [kafka] Add schema-aware JSON Produce

  #4682·gyang94 opened Oct 17, 2026Contributor·

  ·
  1

• [kafka] Convert JSON scalar values to Fluss types

  #4680·gyang94 opened Oct 17, 2026Contributor·

  ·
  1

• [kafka] Separate value decoding and preserve record metadata

  #4678·gyang94 opened Oct 17, 2026Contributor·

  ·
  1

• [metrics] Add a Datadog metrics reporter

  #4672·firasbouzazi opened Oct 16, 2026Contributor·1 task done·

  ·
  1

• [flink] Flush finished tiering tables when closing enumerator

  #4663·Jackeyzhe opened Oct 16, 2026Contributor·

  ·

• [flink] Close discarded lake snapshot iterators safely

  #4661·jonah-rpo opened Oct 15, 2026Contributor·

  ·
  1

• [lake] Refuse reserved Iceberg write modes set through the iceberg. prefix

  #4659·aphenix-r7 opened Oct 15, 2026·1 of 2 tasks·

  ·
  1

  5

• [server] Preserve recreated table mapping during old cleanup

  #4657·luoyuxia opened Oct 15, 2026Contributor·1 of 2 tasks·

  ·
  1

  1

• [build] Extract Spark CI into a separate workflow

  #4654·Yohahaha opened Oct 15, 2026Contributor·

  ·
  4

• [Server] improve CI test time for netty

  component=server
  #4645·polyzos opened Oct 14, 2026Contributor·

  ·

  · v1.1
  1

  7

• [FIP-29][rpc] Wire TLS encryption into the server Netty pipeline

  #4644·morazow opened Oct 14, 2026Contributor·1 of 2 tasks·

  ·
  1

  2

• [build] Use RAT0.18 configuration options and remove deprecation warnings in build

  #4643·ottlinger opened Oct 14, 2026·

  ·
  1

  3

• [FIP-29][security] Add SslPrincipalMapper for certificate DN to principal mapping

  #4641·morazow opened Oct 14, 2026Contributor·

  ·
  1

  2

• [rust] remove the duplicate proto definition

  #4636·zuston opened Oct 14, 2026Member·

  ·
  1

  4

• [python] Add prefix lookup example and documentation

  #4632·JandyTenedora opened Oct 13, 2026Contributor·

  ·
  2

• [server] Eliminate global lock for LOG tablet creation/deletion/load

  #4621·zuston opened Oct 13, 2026Member·

  ·
  6

• [lake/paimon] Promote existing Paimon log tables to Fluss lake tables

  #4619·luoyuxia opened Oct 12, 2026Contributor·

  ·
  6

• [server] Fix stale remote log metrics on repeated leader updates

  #4618·fxbing opened Oct 12, 2026Contributor·

  ·
  1

• [rust] Expose source schema IDs in Arrow batch scans

  #4616·spoon-lz opened Oct 12, 2026Contributor·

  ·
  1

• [rust] Reuse Arrow columns for identity schema alignment

  #4614·spoon-lz opened Oct 12, 2026Contributor·

  ·
  1

  1

• [kv] Support partitioned metadata with HyperClockCache

  #4612·platinumhamburg opened Oct 12, 2026Contributor·

  ·
  5

• [rust] Return decoded scan batches before later errors

  #4606·spoon-lz opened Oct 12, 2026Contributor·

  ·
  1

  6