All pull requests

Pull requests

• fix(spark): stop data skipping through overflowing arithmetic

  size:L
  #20532·voonhous opened Nov 5, 2026Member·3 tasks done·

  ·
  1

  1

• fix(common): normalize logical-type ordering values of Avro engine records

  size:M
  #20529·nsivabalan opened Nov 4, 2026Contributor·3 tasks done·

  ·
  1

• fix(spark): guard data skipping on a timestamp's local date against fall-backs across midnight

  size:M
  #20526·wombatu-kun opened Nov 4, 2026Contributor·3 tasks done·

  ·
  1

  4

• fix(trino): read inline parquet log blocks in snapshot queries

  size:L
  #20523·ad1happy2go opened Nov 4, 2026Collaborator·3 tasks done·

  ·
  1

  1

• fix(spark): guard date_format/from_unixtime data skipping against DST in the session zone

  size:M
  #20521·wombatu-kun opened Nov 4, 2026Contributor·3 tasks done·

  ·
  1

  13

• fix(flink): preserve IN matches when literal list contains NULL

  size:S
  #20517·cshuo opened Nov 4, 2026Collaborator·2 of 3 tasks·

  ·
  1

  1

• feat(spark)!: define streaming source recovery strategies

  size:L
  #20516·danny0405 opened Nov 4, 2026Contributor·3 tasks done·

  ·
  15

• test(spark): cover incremental SDP table chaining

  size:M
  #20515·danny0405 opened Nov 4, 2026Contributor·3 tasks done·

  ·
  6

• fix(flink): conservatively handle NOT in data skipping

  size:S
  #20512·cshuo opened Nov 4, 2026Collaborator·2 of 3 tasks·

  ·
  1

  1

• test: retry Hive and ZooKeeper test services on port conflicts

  size:XL
  #20509·TakuyaInoue-github opened Nov 3, 2026·3 tasks done·

  ·
  1

  2

• fix(spark): skip prepped SQL UPDATE and DELETE on tables without record key meta fields

  size:M
  #20506·PDGGK opened Nov 3, 2026Contributor·3 tasks done·

  ·
  1

  1

• fix(common): allow time travel to a savepointed instant after clean

  size:S
  #20497·sumitsingh-in opened Nov 2, 2026Contributor·3 tasks done·

  ·
  1

  6

  

• fix(spark): validate partitions and cover keyed SDP flows

  size:M
  #20496·danny0405 opened Nov 2, 2026Contributor·3 tasks done·

  ·
  9

• chore(deps-dev): bump pyarrow from 18.1.0 to 23.0.1 in /hudi-agent-gateway

  dependenciespythonsize:XS
  #20490·dependabot[bot] opened Nov 2, 2026Bot·

  ·

• fix(utilities): Allow initializing hudi table on an existing empty path

  size:S
  #20487·wangxianghu opened Oct 30, 2026Contributor·3 tasks·

  ·
  6

• fix(client): Handle incomplete Kafka checkpoint comparisons safely

  size:L
  #20486·fhan688 opened Oct 30, 2026Contributor·2 of 3 tasks·

  ·
  14

• fix(hive-sync): sync unions of multiple non-null types as struct

  size:M
  #20483·prashantwason opened Oct 30, 2026Member·3 tasks done·

  ·
  11

• docs(rfc): add RFC-110 native full-text search index

  size:L
  #20478·linliu-code opened Oct 29, 2026Contributor·2 of 3 tasks·

  ·
  1

• chore(ci): run fork PRs' Java CI on the contributor's fork

  size:XL
  #20476·voonhous opened Oct 29, 2026Member·3 tasks done·

  ·
  2

• chore(ci): bridge fork CI coverage to Codecov for the PR

  size:XL
  #20475·voonhous opened Oct 29, 2026Member·3 tasks done·

  ·
  1

• feat(spark): add Superset and Zeppelin Spark Connect integration

  size:XL
  #20467·cshuo opened Oct 29, 2026Collaborator·2 of 3 tasks·

  ·
  1

  8

• chore(deps): bump pyarrow from 18.1.0 to 23.0.1 in /hudi-lakehouse/local-dev/example

  dependenciespythonsize:XS
  #20463·dependabot[bot] opened Oct 29, 2026Bot·

  ·

• test(spark): add Spark Connect quickstart validation

  size:XL
  #20462·cshuo opened Oct 29, 2026Collaborator·2 of 3 tasks·

  ·
  1

  9

• docs(rfc): RFC-116 Support Branches and Tags

  size:L
  #20459·cshuo opened Oct 28, 2026Collaborator·2 of 3 tasks·

  ·
  14

  

• test(spark): add Spark Connect SDP integration harness and CI coverage

  size:L
  #20453·danny0405 opened Oct 28, 2026Contributor·3 tasks done·

  ·
  1

  5