Skip to content

Pull requests: apache/hudi

New pull request New
474 Open 10,780 Closed
474 Open 10,780 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

perf: Add HoodieROPathFilter support during file listing to prevent driver OOM size:M PR with lines of changes in (100, 300]
#18136 opened Feb 8, 2026 by suryaprasanna Loading…
3 tasks done
1
feat(table-services): Emit archival metrics for monitoring and debugging size:L PR with lines of changes in (300, 1000]
#18133 opened Feb 8, 2026 by nada-attia Loading…
3 tasks done
1
1
fix: timestamp logical types size:XL PR with lines of changes > 1000
#18132 opened Feb 8, 2026 by linliu-code • Draft
3 tasks
1
feat: add flink stream read metrics for hudi source v2 size:S PR with lines of changes in (10, 100]
#18130 opened Feb 8, 2026 by HuangZhenQiu Loading…
3 tasks
5
fix(spark) Empty write should not cause spark analysis errors with pre-commit validators size:M PR with lines of changes in (100, 300]
#18128 opened Feb 8, 2026 by kbuci Loading…
3 tasks
1
feat(flink): Add Kafka offset tracking to Flink Hudi commits size:XL PR with lines of changes > 1000
#18127 opened Feb 8, 2026 by shangxinli Loading…
5 tasks done
2
fix: Support data pruning using nested partition columns size:M PR with lines of changes in (100, 300]
#18126 opened Feb 7, 2026 by linliu-code Loading…
3 tasks
2
feat(flink): Add helper functions to parse Kafka offset differences b… engine:flink Flink integration size:L PR with lines of changes in (300, 1000]
#18125 opened Feb 7, 2026 by shangxinli Loading…
5 tasks done
@prashantwason
2
improvement(spark): ZooKeeper node should hold spark app id (for helping debug when lock is held for long time) size:M PR with lines of changes in (100, 300]
#18123 opened Feb 7, 2026 by kbuci Loading…
2 of 3 tasks
1
fix: Adding support for encoding with Timeline Server interaction
#18121 opened Feb 7, 2026 by nsivabalan Loading…
3 tasks
1
fix: correct unsigned int conversion in TestProtoConversionUtil size:XS PR with lines of changes in <= 10
#18120 opened Feb 7, 2026 by suryaprasanna Loading…
3 tasks done
4
fix: Improve error message for conflict resolution size:M PR with lines of changes in (100, 300]
#18119 opened Feb 6, 2026 by vinishjail97 Loading…
3 tasks done
5
feat(blob): Blob schema definition size:L PR with lines of changes in (300, 1000]
#18108 opened Feb 6, 2026 by the-other-tim-brown • Draft
3 tasks
1
fix: infer record merge mode for pre-v9 tables in generateRequiredSchema size:S PR with lines of changes in (10, 100]
#18106 opened Feb 6, 2026 by vamsikarnika Loading…
3 tasks done
1
[MINOR] Remove redundant local variable from DynamoDBBasedImplicitPartitionKeyLockProvider size:XS PR with lines of changes in <= 10
#18104 opened Feb 6, 2026 by lokeshj1703 Loading…
3 tasks
2
fix(flink): Fix hotpots in stream read size:M PR with lines of changes in (100, 300]
#18103 opened Feb 6, 2026 by Joy-2000 Loading…
3 tasks
8
[WIP] perf: Skip reading file slice only containing an initial log file whe…
#18102 opened Feb 6, 2026 by cshuo Loading…
3 tasks
fix: timestamp logical type fixes size:XL PR with lines of changes > 1000
#18100 opened Feb 5, 2026 by PavithranRick Loading…
3 tasks
1
[draft] Blob reader size:XL PR with lines of changes > 1000
#18098 opened Feb 5, 2026 by the-other-tim-brown • Draft
3 tasks
1
[MINOR] Fix HoodieLockMetrics.createTimerForMetrics to not share metric timer size:XS PR with lines of changes in <= 10
#18097 opened Feb 5, 2026 by lokeshj1703 Loading…
3 tasks
2
[DNM] Branch 0.x with logic types fix debug size:XL PR with lines of changes > 1000
#18096 opened Feb 5, 2026 by lokeshj1703 • Draft
3 tasks
1
fix: sort partitions after filtering size:S PR with lines of changes in (10, 100]
#18092 opened Feb 4, 2026 by prashantwason Loading…
3 tasks done
1
fix(flink): include exception stacktrace in error logs size:XS PR with lines of changes in <= 10
#18091 opened Feb 4, 2026 by prashantwason Loading…
3 tasks done
5
fix(flink): Use timestamp based partitioning in AutoRowDataKeyGen size:S PR with lines of changes in (10, 100]
#18090 opened Feb 4, 2026 by prashantwason Loading…
3 tasks done
3
fix(concurrency): detect rollback conflicts with ongoing commit operations size:M PR with lines of changes in (100, 300]
#18089 opened Feb 4, 2026 by prashantwason Loading…
3 tasks done
1
ProTip! Add no:assignee to see everything that’s not assigned.