Google Git Google Git
Sign in
apache/hudi/HEAD
  1. d1ec4d3 docs(rfc): claim RFC-116 for branch and tag support (#20456) by Shuo Cheng · 12 hours ago master
  2. 82d724b feat(agent): add Flink catalog and metastore composition to Hudi Architect (#20419) by fhan · 18 hours ago
  3. f2e0b66 feat(utilities): add fail-fast continuous mode for HoodieMultiTableStreamer (#19811) by Srikanth Mamidala · 25 hours ago
  4. c0ed524 fix(spark): read shredded variant leaves like Spark 4 (#20332) by voonhous · 29 hours ago
  5. f39f997 fix(spark): create Hudi tables via the DSv2 Column API and accept unchanged properties in HoodieCatalog (#20426) by Sivabalan Narayanan · 2 days ago
  6. 53d0b14 fix(spark): re-create the streaming sink write client when the writer schema changes (#20415) by Sivabalan Narayanan · 2 days ago
  7. 6ac51eb fix(core): write the key generator class for tables below version 8 (#20276) by Y Ethan Guo · 2 days ago
  8. e4c9512 feat(spark): stop forcing direct markers in the streaming sink (#20413) by Sivabalan Narayanan · 2 days ago
  9. 9a43cc1 fix(spark): reuse one embedded timeline server across streaming sink micro-batches (#20412) by Sivabalan Narayanan · 3 days ago
  10. 2f835a5 feat(agent): add Hudi optimizer catalogs and Agent (#20197) by Sivabalan Narayanan · 3 days ago
  11. 74c6125 feat(agent): add Hudi config catalog generator and config-consultant skill (#20195) by Sivabalan Narayanan · 3 days ago
  12. c010ad7 fix(agent): treat existing-table identity mismatch as evidence conflict (#20410) by fhan · 3 days ago
  13. 62bae02 chore(ci): show pr_compliance.py self-test failures (#20422) by voonhous · 5 days ago
  14. 67b3946 chore(ci): run bundle validation on Spark 3.5.9 instead of 3.5.1 (#20428) by Y Ethan Guo · 5 days ago
  15. 00a49c5 chore(ci): build the bundle validation base image on glibc (#20417) by Y Ethan Guo · 5 days ago
  16. 97bdd5b feat(spark): add hudi-spark-native-bundle packaging Apache DataFusion Comet (#19674) by Y Ethan Guo · 6 days ago
  17. 1c54bd3 chore(ci): run all validation in one validate-pr-and-source job (#20421) by voonhous · 6 days ago
  18. 2aae125 chore(ci): require only the validate-pr-and-source check (#20420) by voonhous · 6 days ago
  19. 617be49 fix(flink): apply the nested array reader fix to Flink 1.19 and later (#20399) by Shihuan Liu · 6 days ago
  20. 59ad99f feat(flink): report the steps of a Hive sync in the write coordinator metrics (#20165) by Shihuan Liu · 6 days ago
  21. 42913d0 fix(utilities): Re-add _corrupt_record when a transformer drops it in ErrorTableAwareChainedTransformer (#20336) by Raghuramchadalawada · 6 days ago
  22. 1d5462b chore(ci): pin ubuntu-latest runners to ubuntu-24.04 (#20418) by voonhous · 6 days ago
  23. 2b6d8b2 refactor(agent): move the Hudi Architect skill under hudi-ai-operator (#20223) by Sivabalan Narayanan · 6 days ago
  24. a974f44 feat(utilities): add record-level index sizing check to HoodieTableHealthChecker (#20153) by Sivabalan Narayanan · 6 days ago
  25. fe8627a docs(agent): correct the HoodieTableHealthChecker exit codes in the hudi-table-health skill (#20385) by Sivabalan Narayanan · 6 days ago
  26. 5cce63e feat(utilities): add metadata table sync and compaction lag checks to HoodieTableHealthChecker (#20154) by Sivabalan Narayanan · 6 days ago
  27. 0f9f6b7 feat(agent): add Hudi RCA skill with failure catalog, mitigation ladders and workflow catalog (#20194) by Sivabalan Narayanan · 6 days ago
  28. bb42885 feat(utilities): add HoodieSparkEventLogAnalyzer for Hudi-aware Spark stage analysis (#20196) by Sivabalan Narayanan · 6 days ago
  29. 8c4a836 chore(ci): flatten the Java CI job graph (#19890) by voonhous · 7 days ago
  30. 483bf71 feat(agent): add existing-table reconciliation to Hudi Architect (#20391) by fhan · 7 days ago
  31. 31f4a5e fix(common): write ordering values to native delete logs in their stored form (#20373) by Vova Kolmakov · 8 days ago
  32. 59561a8 test(common): cover array fields in parquet-avro GenericData reader test (#20190) by databird07 · 8 days ago
  33. 5b8323f fix(spark): resolve nested ordering fields for Spark deletes written to delete blocks (#20368) by Vova Kolmakov · 8 days ago
  34. b5b05d1 fix(flink): unwrap the list element type when creating vectors for nested arrays (#20337) by Shihuan Liu · 8 days ago
  35. a0313d1 feat(utilities): add HoodieTableLayoutAnalyzer for small-file, micro-partition and hot-partition detection (#20152) by Sivabalan Narayanan · 8 days ago
  36. a6b8744 fix(flink): defer instant creation until earlier checkpoints finish (#20389) by Vova Kolmakov · 9 days ago
  37. 6aeb9a2 fix: escape partition values and locations in Hive sync DDL (#20390) by Danny Chan · 9 days ago
  38. d62850e chore(ci): path-filter Trino CI on pull requests (#20376) by voonhous · 9 days ago
  39. 7ad42f1 chore(ci): run all PR metadata checks in one job (#20375) by voonhous · 9 days ago
  40. 0f07615 chore(ci): require only validate-pr for PR metadata (#20374) by voonhous · 9 days ago
  41. 91ffb05 fix(spark): stop treating lower/upper as order-preserving in data skipping (#20228) by Vova Kolmakov · 9 days ago
  42. e95ecf5 chore: update DOAP for 1.1.2 release (#20382) by Danny Chan · 10 days ago
  43. 9b7a713 fix(spark): preserve delete payloads during record reconstruction (#20341) by Shuo Cheng · 12 days ago
  44. a99e89e feat(agent): Add first executable mutable Flink SQL MOR sink path to Hudi Architect (#20302) by fhan · 12 days ago
  45. 1ba1edc fix(common): widen REQUIRED shredded variant reads (#20351) by voonhous · 12 days ago
  46. 5764e96 feat(utilities): add HoodieTableHealthChecker for table service health (#20151) by Sivabalan Narayanan · 12 days ago
  47. 92771db feat(client): add an opt-in to skip inline metadata table services (#20350) by Sagar Sumit · 12 days ago
  48. 1568ceb fix(spark): stop treating the datediff start date as order-preserving in data skipping (#20230) by Vova Kolmakov · 12 days ago
  49. c82957d fix(gcp): skip "null" type fields when syncing the BigQuery schema (#20356) by Prashant Wason · 13 days ago
  50. c167f7b fix(hive-sync): skip null type fields when syncing the table schema (#20354) by Prashant Wason · 13 days ago
  51. 2cfe6b9 fix(hfile): reject block sizes the HFile format cannot represent (#20321) by Y Ethan Guo · 13 days ago
  52. b6119ca docs(hudi-io): document HFile offset and size widths and the non-root index block layout (#20319) by Y Ethan Guo · 13 days ago
  53. 5dee638 fix(spark): reject variant leaves Spark 4 cannot shred (#20326) by voonhous · 13 days ago
  54. 75fb5d5 fix(common): avoid archive lookups for active clean and rollback instants (#20340) by Danny Chan · 13 days ago
  55. 616f9ae fix(common): dedupe repeated Avro fixed names (#20324) by voonhous · 14 days ago
  56. 0170359 fix(flink): resend recovered write metadata on task retries (#20323) by Danny Chan · 14 days ago
  57. b0ea242 fix(kafka-connect): close AdminClient after fetching topic partitions (#20303) by fhan · 14 days ago
  58. 9086d98 fix(kafka-connect): retry start commit when the topic partition lookup fails (#20312) by Vova Kolmakov · 14 days ago
  59. bc78d06 fix(kafka-connect): treat a completed commit as successful when a post-commit action fails (#20316) by Vova Kolmakov · 14 days ago
  60. 6bbf798 fix(spark): render decimal, date and timestamp values in CDC images (#20305) by Sagar Sumit · 2 weeks ago
  61. 61dde86 fix(flink): make the bucket pruning function serializable for source V2 (#20318) by Vova Kolmakov · 2 weeks ago
  62. 276d120 fix(flink): retain files with missing column statistics (#20295) by Shuo Cheng · 2 weeks ago
  63. fe1c31d fix(hfile): use long cursor offsets in native HFile reader for files larger than 2GB (#20309) by Prashant Wason · 2 weeks ago
  64. 9b39f04 fix(common): correct incremental fallback reads when a stale non-write instant precedes the first active commit (#20273) by Aditya Goenka · 2 weeks ago
  65. aabed46 fix(spark): honor 'earliest' begin instant in DataFrame CDC reads (#20304) by Sagar Sumit · 2 weeks ago
  66. 092e4c4 fix(flink): reclaim empty checkpoint caches in record index (#20241) by Shuo Cheng · 2 weeks ago
  67. b86a34b fix(flink): preserve event-time delete ordering during precombine (#20288) by Shuo Cheng · 2 weeks ago
  68. e9da226 fix(spark): decide vectorized read per scan in HoodieFileGroupReaderBasedFileFormat (#20183) by Sumit Singh · 2 weeks ago
  69. da78989 fix(kafka-connect): terminate transaction coordinator event loop on stop (#20271) by fhan · 2 weeks ago
  70. 790414f refactor: Rename dataFile/df variables to baseFile/bf (#19944) by Nanjesh Ramesh · 2 weeks ago
  71. 0202ca7 perf(core): avoid copying table properties for each native log file (#20297) by Danny Chan · 2 weeks ago
  72. a2d88d9 fix(hive-sync): keep the sync client's metastore client out of Hive's thread cache (#20219) by Shihuan Liu · 2 weeks ago
  73. 45cec1a fix(common): propagate stored disruptor consumer failures (#20026) by Burak Kalaycı · 2 weeks ago
  74. 2d7be92 fix(flink): prevent write rate limiter stalls and thread leaks (#20189) by fhan · 2 weeks ago
  75. 9a629fd feat(agent): add first mutable Flink SQL COW sink path to Hudi Architect (#20281) by fhan · 2 weeks ago
  76. a41f6ea fix(spark): keep variant guard under nested filter pushdown (#20201) by voonhous · 2 weeks ago
  77. 3aa7fe2 feat(agent): add first executable Flink SQL sink path to Hudi Architect (#20198) by fhan · 3 weeks ago
  78. 9794ece fix(flink): close bulk insert writer helper during cleanup (#20242) by Shuo Cheng · 3 weeks ago
  79. 308f78e fix(spark): skip the catalog lookup in HoodieFileIndex unless the read declares a bucket index (#20240) by Y Ethan Guo · 3 weeks ago
  80. 17e3650 fix(timeline-service): skip redundant refreshes for trailing cleans (#19946) by Goutam Adwant · 3 weeks ago
  81. 43904a9 fix(build): resolve same-module Scala classes when generating javadoc (#20238) by Y Ethan Guo · 3 weeks ago
  82. 4f4c357 fix(spark): match SQL option names exactly when ignoring case (#20144) by fhan · 3 weeks ago
  83. 4cfba4c fix(HUDI-9666): read the table's timeline layout in upgrade_table, hudi-cli upgrade and rollback_to_instant (#20063) by Aditya Goenka · 3 weeks ago
  84. a11dae4 perf(spark): enable vectorized reading and file splitting for COW incremental reads (#19914) by Prashant Wason · 3 weeks ago
  85. 7f35e7e test(spark): guard against executor .hoodie access and task payload growth on the read path (#20112) by Y Ethan Guo · 3 weeks ago
  86. 7e4c944 chore: fix javadoc and compiler warnings flagged in CI (#20215) by Y Ethan Guo · 3 weeks ago
  87. b6fe7c3 fix(metrics): handle stale DistributedRegistry across SparkContext restarts (#19790) by Prashant Wason · 3 weeks ago
  88. 211ccba fix(spark): avoid full partition listing in incremental reads (#19898) by Prashant Wason · 3 weeks ago
  89. 296f5d8 fix(spark): fix incremental file index reporting sizeInBytes=0 (#19912) by Prashant Wason · 3 weeks ago
  90. 379f566 fix(Spark): Fix nested struct predicate pushdown for HoodieFileGroupReaderBasedFileFormat (#20029) by Prashant Wason · 3 weeks ago
  91. ec2831e perf(spark): check file existence in parallel in MOR incremental fallback scan (#20211) by Prashant Wason · 3 weeks ago
  92. 77f5e021 fix(build): remove duplicate dependency declarations rejected by Maven 3.10 (#20212) by Prashant Wason · 3 weeks ago
  93. 3b5bb09 fix(writer): reject directory-traversal partition paths across all writers (#19342) by Sivabalan Narayanan · 3 weeks ago
  94. 862f4b9 fix(metadata): key RLI and SI write stats by file group, not file id (#20188) by Vinish Reddy · 3 weeks ago
  95. 438c0d3 fix(spark): group file slices by partition in the file index listing (#20115) by Y Ethan Guo · 3 weeks ago
  96. 1c30d05 perf(spark): stop per-file Hadoop configuration parsing and copies on the parquet read path (#20079) by Y Ethan Guo · 3 weeks ago
  97. 76da56f refactor(core): read file groups from a table state instead of a meta client (#20078) by Y Ethan Guo · 3 weeks ago
  98. 8e0402d fix(hfile): bound compressed block decompression (#19930) by Sherwin Tan · 3 weeks ago
  99. fa254c2 fix(metadata): skip the meta folder when listing partitions from the file system (#20080) by Y Ethan Guo · 3 weeks ago
  100. 2fc6486 perf(spark): ship file group reader scan state once per executor (#20077) by Y Ethan Guo · 3 weeks ago