-
Notifications
You must be signed in to change notification settings - Fork 2.5k
Pull requests: apache/hudi
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
feat(hive-sync): parallelize DROP partitions in HiveQL sync mode
#19033
opened Jun 17, 2026 by
nsivabalan
Contributor
Loading…
4 tasks done
test(flink): retry short CollectSink reads to de-flake stream-read ITs
#19030
opened Jun 17, 2026 by
wombatu-kun
Contributor
Loading…
3 tasks done
fix(schema): permit opt-in timestamp-precision evolution
#19029
opened Jun 17, 2026 by
yihua
Contributor
Loading…
3 tasks done
fix: initialize lastCompletedTxnAndMetadata before recommitInstant in Flink StreamWriteOperatorCoordinator
size:S
PR with lines of changes in (10, 100]
#19023
opened Jun 16, 2026 by
suryaprasanna
Contributor
Loading…
3 tasks done
perf(io): Avoid per-entry KeyValue allocation in HFileDataBlock.seekTo
area:performance
Performance optimizations
size:S
PR with lines of changes in (10, 100]
#19021
opened Jun 16, 2026 by
wombatu-kun
Contributor
Loading…
3 tasks done
fix(build): declare lombok in annotationProcessorPaths to deflake parallel-build compilation
size:S
PR with lines of changes in (10, 100]
#19020
opened Jun 16, 2026 by
wombatu-kun
Contributor
Loading…
3 tasks
perf(kafka-connect): avoid per-record TopicPartition allocation in HoodieSinkTask.put
area:performance
Performance optimizations
size:S
PR with lines of changes in (10, 100]
#19018
opened Jun 16, 2026 by
wombatu-kun
Contributor
Loading…
3 tasks
feat(flink): Support data skipping based on partitioned RLI
size:L
PR with lines of changes in (300, 1000]
#19006
opened Jun 15, 2026 by
cshuo
Collaborator
Loading…
3 tasks
fix(spark): runtime-merge full file groups for MOR incremental queries (#18943)
size:L
PR with lines of changes in (300, 1000]
#19005
opened Jun 15, 2026 by
ad1happy2go
Collaborator
Loading…
3 tasks done
test(trino): de-flake TestHudi*FileOperations by asserting only synchronous reads
size:M
PR with lines of changes in (100, 300]
#19004
opened Jun 14, 2026 by
wombatu-kun
Contributor
Loading…
3 tasks done
perf(spark): restore Catalyst fast-paths for SimpleKeyGen/Nonpartitioned bulk insert
area:performance
Performance optimizations
size:L
PR with lines of changes in (300, 1000]
#18990
opened Jun 12, 2026 by
nsivabalan
Contributor
Loading…
3 tasks done
feat(client): enrich write commit callback message and fire it for table-service commits
size:L
PR with lines of changes in (300, 1000]
#18988
opened Jun 12, 2026 by
codope
Member
Loading…
3 tasks done
feat:(DNM) add a lsm-tree based FG reader
size:XL
PR with lines of changes > 1000
#18987
opened Jun 12, 2026 by
danny0405
Contributor
Loading…
3 tasks
feat(hive-sync): batch and parallelize JDBC partition operations
size:XL
PR with lines of changes > 1000
#18986
opened Jun 12, 2026 by
nsivabalan
Contributor
•
Draft
5 of 6 tasks
feat(hive-sync): batch and parallelize HiveQL partition operations
size:XL
PR with lines of changes > 1000
#18984
opened Jun 12, 2026 by
nsivabalan
Contributor
•
Draft
7 of 8 tasks
feat(hive-sync): batch and parallelize HMS partition operations
size:L
PR with lines of changes in (300, 1000]
#18983
opened Jun 11, 2026 by
nsivabalan
Contributor
•
Draft
4 of 5 tasks
[HUDI-18139] fix(spark): make post-sync Spark catalog cache refresh best-effort
size:M
PR with lines of changes in (100, 300]
#18975
opened Jun 11, 2026 by
ad1happy2go
Collaborator
Loading…
3 tasks done
fix(spark): support consistent hashing clustering on non-partitioned tables
size:S
PR with lines of changes in (10, 100]
#18968
opened Jun 10, 2026 by
ad1happy2go
Collaborator
Loading…
3 tasks done
perf(common): Avoid per-record HoodieSchema rebuilds on Avro read/merge paths
area:performance
Performance optimizations
size:M
PR with lines of changes in (100, 300]
#18967
opened Jun 10, 2026 by
voonhous
Member
Loading…
3 tasks done
feat(variant): [DNM] auto-infer per-file variant shredding schemas on shredding inference
size:XL
PR with lines of changes > 1000
#18961
opened Jun 10, 2026 by
voonhous
Member
Loading…
3 tasks done
docs(datasource): START_COMMIT is exclusive, not inclusive
size:S
PR with lines of changes in (10, 100]
fix(streamer): Include start commit in S3/GCS IncrSource incremental query
size:M
PR with lines of changes in (100, 300]
Previous Next
ProTip!
Find all pull requests that aren't related to any open issues with -linked:issue.