All pull requests

Pull requests

• docs(blog): translate JD.com's Fluss and Hudi blog to English

  docssize:M
  #20342·yihua opened Oct 15, 2026Contributor·2 of 3 tasks·

  ·

• fix: preserve delete payloads in Spark and Avro record reconstruction

  size:M
  #20341·cshuo opened Oct 15, 2026Collaborator·2 of 3 tasks·

  ·
  1

  1

• fix(common): avoid archive lookups for active clean and rollback instants

  size:S
  #20340·danny0405 opened Oct 15, 2026Contributor·3 tasks done·

  ·
  4

• fix(flink): serialize coordinator recovery with checkpoint commits

  size:S
  #20339·cshuo opened Oct 15, 2026Collaborator·2 of 3 tasks·

  ·
  1

  3

• fix(flink): unwrap the list element type when creating vectors for nested arrays

  size:L
  #20337·skywalker0618 opened Oct 14, 2026Contributor·3 tasks done·

  ·
  9

• fix(utilities): Preserve _corrupt_record across transformers that drop it in ErrorTableAwareChainedTransformer

  size:M
  #20336·Raghuramchadalawada opened Oct 14, 2026·3 tasks done·

  ·
  1

  7

• [HUDI] Add Delta Lake style VERSION AS OF time travel support

  size:M
  #20334·y2ksayed opened Oct 14, 2026·

  ·
  8

  

• feat(metadata)!: allow a files-partition entry to point outside the table base path

  size:L
  #20333·shangxinli opened Oct 14, 2026Contributor·3 tasks done·

  ·
  19

• fix(spark): read shredded variant leaves like Spark 4

  size:XL
  #20332·voonhous opened Oct 14, 2026Member·3 tasks done·

  ·
  1

  1

• feat(gateway): add Spark Connect SQL backend

  size:XL
  #20329·cshuo opened Oct 14, 2026Collaborator·2 of 3 tasks·

  ·
  1

• fix(spark): retain matching files with missing column statistics

  size:M
  #20328·cshuo opened Oct 14, 2026Collaborator·2 of 3 tasks·

  ·
  1

  3

• fix(spark): reject variant leaves Spark 4 cannot shred

  size:M
  #20326·voonhous opened Oct 14, 2026Member·3 tasks done·

  ·
  1

  6

• fix(common): dedupe repeated Avro fixed names

  size:S
  #20324·voonhous opened Oct 14, 2026Member·3 tasks done·

  ·
  1

  7

• fix(hfile): reject block sizes the HFile format cannot represent

  size:M
  #20321·yihua opened Oct 14, 2026Contributor·3 tasks done·

  ·
  1

  5

  

• docs(hudi-io): document HFile offset and size widths and the non-root index block layout

  size:M
  #20319·yihua opened Oct 14, 2026Contributor·2 of 3 tasks·

  ·
  3

  

• fix(flink): align bucket pruning with field-prefixed record keys

  size:L
  #20314·wombatu-kun opened Oct 14, 2026Contributor·3 tasks done·

  ·
  1

  12

• fix(archival)!: stop archiving beyond savepoint, which leaves timeline holes

  size:L
  #20310·nsivabalan opened Oct 13, 2026Contributor·3 tasks done·

  ·
  4

• feat(agent): Add first executable mutable Flink SQL MOR sink path to Hudi Architect

  size:XL
  #20302·fhan688 opened Oct 13, 2026Contributor·2 of 3 tasks·

  ·
  4

• fix(flink): treat missing column stats as unknown after index expansion

  size:S
  #20298·csarushan1729 opened Oct 13, 2026·3 tasks done·

  ·
  1

  4

• fix(flink): preserve timestamp precision in predicates and indexes

  size:L
  #20294·cshuo opened Oct 13, 2026Collaborator·2 of 3 tasks·

  ·
  1

  5

• fix(flink): align bucket pruning with compound key placeholders

  size:S
  #20292·cshuo opened Oct 13, 2026Collaborator·2 of 3 tasks·

  ·
  1

  6

• [UBER] Add async pre-write rollback support

  size:M
  #20290·vamshipasunuru1 opened Oct 12, 2026Contributor·

  ·
  11

• Add Hadoop configuration directory hadoop_conf.dir support for Flink cross-cluster Hudi read/write

  size:L
  #20285·cbg-wx opened Oct 11, 2026·3 tasks·

  ·
  6

• fix(common): map every meta-fields mode but NONE to the legacy populated boolean

  size:S
  #20282·vamshipasunuru1 opened Oct 10, 2026Contributor·3 tasks done·

  ·
  8

• fix(core): write the key generator class for tables below version 8

  size:L
  #20276·yihua opened Oct 9, 2026Contributor·3 tasks done·

  ·
  1

  3