Skip to content

Pull requests: apache/hudi

New pull request New
548 Open 11,955 Closed
548 Open 11,955 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

feat(trino): extract HudiExecutorModule for lakehouse reuse size:M PR with lines of changes in (100, 300]
#20008 opened Sep 19, 2026 by voonhous Member Loading…
3 tasks done
2
feat(trino): extract HudiExecutorModule for lakehouse reuse size:M PR with lines of changes in (100, 300]
#20007 opened Sep 19, 2026 by voonhous Member Loading…
3 tasks done
1
2
feat(trino): accept hudi.max-split-size as an alias size:S PR with lines of changes in (10, 100]
#20006 opened Sep 19, 2026 by voonhous Member Loading…
3 tasks done
1
2
feat(trino): accept hudi.max-split-size as an alias size:S PR with lines of changes in (10, 100]
#20005 opened Sep 19, 2026 by voonhous Member Loading…
3 tasks done
2
feat(common): expose the merged log records of a file group as a map size:L PR with lines of changes in (300, 1000]
#20001 opened Sep 18, 2026 by yihua Contributor • Draft
3 tasks done
1
2
docs(rfc): add RFC-112 for Spark declarative pipelines size:L PR with lines of changes in (300, 1000]
#19997 opened Sep 18, 2026 by cshuo Collaborator Loading…
3 tasks
10
perf(flink): scope column stats reads to candidate partitions size:M PR with lines of changes in (100, 300]
#19992 opened Sep 18, 2026 by danny0405 Contributor Loading…
3 tasks done
5
chore: cache the spark integration test archive size:S PR with lines of changes in (10, 100]
#19986 opened Sep 17, 2026 by abhinav-phi Loading…
3 tasks done
@voonhous
3
fix(common): filter logs by latest commit time in LSM reader size:M PR with lines of changes in (100, 300]
#19984 opened Sep 17, 2026 by cshuo Collaborator Loading…
2 of 3 tasks
1
6
fix(spark): apply procedure filters before the limit, not after size:M PR with lines of changes in (100, 300]
#19974 opened Sep 16, 2026 by rangareddy Collaborator • Draft
4 tasks done
1
7
fix(flink): wait for successful heartbeat writes before recommit size:M PR with lines of changes in (100, 300]
#19971 opened Sep 16, 2026 by cshuo Collaborator Loading…
2 of 3 tasks
1
10
[HUDI-96] Support named arguments for SparkMain CLI commands size:L PR with lines of changes in (300, 1000]
#19970 opened Sep 16, 2026 by zhang-arvin Loading…
14
[HUDI-19878] Initialize Spark context for record index deletion size:S PR with lines of changes in (10, 100]
#19969 opened Sep 16, 2026 by txwyy123 Loading…
1
2
test(spark): cover partitioned RLI on a hive-style partition column containing a dot size:S PR with lines of changes in (10, 100]
#19964 opened Sep 15, 2026 by yihua Contributor • Draft
3 tasks
2
fix(flink): serve instant-time requests asynchronously to avoid coordination RPC timeout size:L PR with lines of changes in (300, 1000]
#19960 opened Sep 15, 2026 by fhan688 Contributor Loading…
3 tasks
1
9
fix(flink): reuse coordinator pending fileIds to avoid duplicate bucket fileId after recommit race size:L PR with lines of changes in (300, 1000]
#19951 opened Sep 15, 2026 by zhaoyudi-creator Contributor Loading…
3 tasks
15
fix(spark): propagate incremental instant range to MOR file group reader size:M PR with lines of changes in (100, 300]
#19948 opened Sep 14, 2026 by fhan688 Contributor Loading…
3 tasks done
@yihua
9
perf(timeline-service): avoid refreshing exact timeline extensions size:L PR with lines of changes in (300, 1000]
#19946 opened Sep 14, 2026 by goutamadwant Loading…
3 tasks done
1
8
[HUDI-1610] Add SCALAR timestamp type coverage to TestCOWDataSource size:S PR with lines of changes in (10, 100]
#19945 opened Sep 14, 2026 by nanjeshramesh Loading…
3 tasks done
1
3
refactor: Rename dataFile/df variables to baseFile/bf size:L PR with lines of changes in (300, 1000]
#19944 opened Sep 14, 2026 by nanjeshramesh Loading…
3 tasks done
1
9
fix(utilities): count error-table records before committing the error table size:L PR with lines of changes in (300, 1000]
#19940 opened Sep 13, 2026 by yihua Contributor Loading…
3 tasks done
9
chore(ci): fold hadoop-mr job into utilities-rest size:XL PR with lines of changes > 1000
#19933 opened Sep 13, 2026 by voonhous Member Loading…
3 tasks done
2
test(spark): run other-2's SQL suites in parallel size:XL PR with lines of changes > 1000
#19932 opened Sep 13, 2026 by voonhous Member Loading…
3 tasks done
2
chore(ci): time out the Spark test jobs at 75 min size:XL PR with lines of changes > 1000
#19931 opened Sep 12, 2026 by voonhous Member Loading…
3 tasks done
2
fix(hfile): bound compressed block decompression size:M PR with lines of changes in (100, 300]
#19930 opened Sep 12, 2026 by txwyy123 Loading…
2 of 3 tasks
@linliu-code
4
ProTip! Type g p on any issue or pull request to go back to the pull request listing page.