All pull requests

Pull requests

• [flink] Keep NOT NULL of VARIANT columns created through Flink

  #10617·LuciferYang opened Oct 16, 2026Contributor·

  ·
  1

• [flink] Restore rewrite_file_index jobs from checkpoints

  #10615·LuciferYang opened Oct 16, 2026Contributor·

  ·
  1

• [flink] Support TIMESTAMP columns in ANALYZE TABLE column statistics

  #10613·LuciferYang opened Oct 16, 2026Contributor·

  ·
  1

• [flink] Do not fail partition_idle_time compaction on partitions written after the job is built

  #10612·LuciferYang opened Oct 16, 2026Contributor·

  ·
  1

• [python] Use Native scan statistics in explain

  #10609·JingsongLi opened Oct 16, 2026Contributor·

  ·

• [python] Support constructing BlobView and BlobViewStruct by field name

  #10608·zhuanshenbsj1 opened Oct 16, 2026Contributor·

  ·
  2

• [core] Optimize FieldCollectAgg with equaliser when count-limit is negative

  #10607·tsreaper opened Oct 16, 2026Contributor·

  ·
  2

• [parquet] Write TIMESTAMP_LTZ(<=3) as TIMESTAMP_MICROS when Iceberg compatibility is enabled

  #10601·0dunay0 opened Oct 15, 2026Contributor·

  ·
  1

  4

• [rest] Align the OpenAPI spec, RESTApi, pypaimon and openapi-v4 actions, checked in CI

  #10599·sundapeng opened Oct 15, 2026Member·

  ·
  4

• [core] Preserve reused compaction files when aborting commits

  #10582·Zerolzj opened Oct 15, 2026·

  ·
  5

• [WIP][python] Log FileIO cache and Jindo stream health at a bounded rate

  #10580·sundapeng opened Oct 15, 2026Member·

  ·

• [WIP][python] Drop expired tokens from the token cache of RESTTokenFileIO

  #10573·sundapeng opened Oct 15, 2026Member·

  ·

• [python] Externalize primary-key BLOBs and keep shared packs reachable.

  #10570·Stephen0421 opened Oct 14, 2026Contributor·

  ·
  24

• [spark] Distribute batch vector search across the cluster

  #10569·Stephen0421 opened Oct 14, 2026Contributor·

  ·
  2

• [core] Resume unfinished full-compaction commits while preserving snapshot semantics

  #10568·jordepic opened Oct 14, 2026Contributor·

  ·
  2

• [core] Detect stale deletion vectors in fixed-bucket compaction commits

  #10564·discivigour opened Oct 14, 2026Contributor·

  ·

• [python] Add actor commit mode to the Ray write path

  #10541·hameizi opened Oct 13, 2026·

  ·
  17

• [python] Support distributed LeRobot import with Ray

  #10483·XiaoHongbo-Hope opened Oct 10, 2026Contributor·

  ·
  5

• [python] Improve Vortex scans and expose compact compression

  #10409·joseph-isaacs opened Oct 6, 2026·

  ·
  2

• [python] Reduce named Variant projection output overhead

  #10398·XiaoHongbo-Hope opened Oct 5, 2026Contributor·

  ·

• [python] Normalize nested naive timestamps when writing Avro to object stores and HDFS

  #10356·jackylee-ch opened Oct 3, 2026Contributor·

  ·
  1

• [python] Support per-request endpoint routing for io-cache

  #10351·sundapeng opened Oct 3, 2026Member·

  ·
  3

• [jindo] Support per-request endpoint routing for io-cache

  #10350·sundapeng opened Oct 3, 2026Member·

  ·
  6

• [flink] Add opt-in changelog-to-append event materialization

  #10341·nleigh opened Oct 2, 2026·

  ·
  1

• [iceberg] Write required Avro metadata to manifest files

  #10329·hutiefang76 opened Oct 1, 2026Contributor·

  ·
  1