All pull requests

Pull requests

• [flink][cdc] Preserve binary values in Debezium JSON and MySQL records

  #10879·taoran92 opened Oct 29, 2026Member·

  ·
  1

• [python] Keep files with NaN float stats in stats-based pruning

  #10877·plusplusjiajia opened Oct 29, 2026Member·

  ·

• [common] Extract a variant into a MAP whose STRING key is NOT NULL

  #10876·thswlsqls opened Oct 29, 2026Contributor·

  ·
  1

• [core] Validate DATE partitions by their date value in partition.timestamp-format.strict

  #10874·thswlsqls opened Oct 29, 2026Contributor·

  ·
  1

• [codegen] Update bundled NOTICE for the Scala 2.12.18 upgrade

  #10870·thswlsqls opened Oct 29, 2026Contributor·

  ·
  1

• [python] Read independent temporal sources concurrently

  #10868·XiaoHongbo-Hope opened Oct 29, 2026Contributor·

  ·

• [core] Support changelog-on-read for primary-key tables

  #10867·discivigour opened Oct 29, 2026Contributor·

  ·

• [python] Include block size in the local disk cache key

  #10866·Stephen0421 opened Oct 29, 2026Contributor·

  ·

• [core] Add delete-row.thin-mode for primary-key tables

  #10863·discivigour opened Oct 29, 2026Contributor·

  ·

• [python] Preserve timestamp precision and UTC instants in ROW writes

  #10862·skyyyy955 opened Oct 29, 2026Contributor·

  ·

• [python] Support named column projections in map-style Torch datasets

  #10861·QuakeWang opened Oct 29, 2026Member·

  ·

• [WIP][core] Handle missing snapshots in branch time travel

  #10860·LsomeYeah opened Oct 29, 2026Contributor·

  ·

• [python] fsync LocalFileIO writes before publishing snapshots

  #10853·xlb3055 opened Oct 28, 2026·

  ·
  1

  3

• [core] Expire TIMESTAMP partitions with the values-time strategy

  #10851·cxzl25 opened Oct 28, 2026Contributor·

  ·

• [core] Defer file-store validation until runtime initialization

  #10850·zhoulii opened Oct 28, 2026Member·

  ·
  1

  3

• [python] Batch temporal alignment metadata and native matching

  #10846·XiaoHongbo-Hope opened Oct 28, 2026Contributor·

  ·
  1

• [core] Keep main's snapshots when fast_forward fails and hold the commit lock

  #10845·LuciferYang opened Oct 28, 2026Contributor·

  ·
  6

• [spark] Partition metadata fails on chain and query-authorized reads

  #10838·taoran92 opened Oct 27, 2026Member·

  ·
  1

  3

• [format]custom parquet parser

  #10836·weijietong opened Oct 27, 2026Contributor·

  ·
  7

• [core][flink] Support lake-stream mode for Flink reads and writes

  #10833·yunfengzhou-hub opened Oct 27, 2026Contributor·

  ·
  2

  7

• [flink] Emit the watermark when local merge flushes an empty buffer

  #10832·LuciferYang opened Oct 27, 2026Contributor·

  ·
  1

  1

• [python] Support primary-key vector search with Ray

  #10828·tzphh opened Oct 27, 2026Contributor·

  ·
  1

  1

• [format] Add csv.skip-empty-lines to skip empty lines when reading CSV

  #10824·COLDMANYU opened Oct 27, 2026Contributor·

  ·
  1

  3

• [python] Use persisted video indexes for TorchCodec frame reads

  #10821·XiaoHongbo-Hope opened Oct 26, 2026Contributor·

  ·

• [python] Support Episode video remux during LeRobot import

  #10819·XiaoHongbo-Hope opened Oct 26, 2026Contributor·

  ·