Google Git
Sign in
apache/hudi/HEAD
  1. 0774d91 chore(ci): modernize Codecov config for the coverage initiative (#19138) by Y Ethan Guo · 16 hours ago master
  2. 4a5d5b0 fix(hive-sync): drop the unreachable HMS lock timeout-recovery path (#19371) by Vova Kolmakov · 17 hours ago
  3. 483dd87 feat(hive-sync): batch and parallelize HiveQL partition operations (#18984) by Sivabalan Narayanan · 22 hours ago
  4. c3c9367 feat(trino): Migrate the Trino-Hudi connector into the Hudi repo (RFC-105) (#18837) by voonhous · 2 days ago
  5. 42e938d fix: Fix lock expiration metric (#18492) by Lin Liu · 2 days ago
  6. 26b1ebc fix(record-index-bootstrap): sort record index keys by UTF-8 bytes to match HFile sorting (#18941) by Nada · 4 days ago
  7. 48fe2c6 fix(hive-sync): stop the HMS lock heartbeat once the metastore drops the lock (#19370) by Vova Kolmakov · 4 days ago
  8. 5039639 chore(deps): bump org.apache.commons:commons-configuration2 (#18801) by dependabot[bot] · 4 days ago
  9. d4d8bfa chore(deps): bump org.apache.thrift:libthrift (#18910) by dependabot[bot] · 4 days ago
  10. dfb763e chore(deps): bump io.airlift:aircompressor from 0.27 to 2.0.3 (#18247) by dependabot[bot] · 4 days ago
  11. e5452c6 feat(spark): upgrade Spark 4.2 dependency to GA 4.2.0 (#19365) by Y Ethan Guo · 4 days ago
  12. 506740a chore(ci): update .asf.yaml required checks for Spark 4.2.0 GA (#19367) by Y Ethan Guo · 4 days ago
  13. a4373f7 test(hudi-client): improve metadata table writer coverage (#19363) by Shuo Cheng · 4 days ago
  14. ebbfcc5 fix(timeline-service): fail marker creation requests when marker flush fails (#19368) by Y Ethan Guo · 4 days ago
  15. 4d11a60 fix(flink): deduplicate delete keys and cover write paths (#19354) by Danny Chan · 5 days ago
  16. 427efb2 fix(flink): normalize row logical conversions and improve coverage (#19351) by Danny Chan · 5 days ago
  17. 5f19cf3 fix(metadata-table): follow-ups for the zero-size file skip (#18611) (#19355) by voonhous · 5 days ago
  18. 30a4ba3 docs(docker): document build_docker_images.sh flags (#18687) by 201573 · 5 days ago
  19. 5a42f89 test(spark): Fix flaky TestSparkFilterHelper by giving it its own SparkSession (#19356) by Vova Kolmakov · 5 days ago
  20. 9f53c46 feat(flink): enable LSM end-to-end for Flink by default (#19307) by Shuo Cheng · 5 days ago
  21. f25e079 fix: Handle map/array-nested leaf columns in column stats collection during MOR log-append (#19126) by Vinish Reddy · 5 days ago
  22. a44829a feat: agentic lakehouse v1 - hudi-lakehouse charts and hudi-agent-gateway (#19265) by vinoth chandar · 5 days ago
  23. 76f81ec fix(flink): make hudi-flink-bundle built with flink-bundle-shade-hive usable for Hive sync (#19330) by Shihuan Liu · 5 days ago
  24. e7b0ba8 test(common): add LSM file group read path coverage (#19347) by Danny Chan · 5 days ago
  25. fb07a2d fix(reader): derive pre-v9 CDC delete markers from the effective payload class (#19348) by Lokesh Jain · 5 days ago
  26. e4071ce chore(utilities): add SQS backlog / in-flight visibility to S3 events source (#19333) by Davis-Zhang-Onehouse · 6 days ago
  27. 76a95f5 fix(utilities): guard Source.releaseResources() against transient RDD unpersist failures (#19328) by Nikhil Kumar · 6 days ago
  28. 9f8376e fix(hive-sync): keep HMS lock heartbeat alive and release its thread pool on close (#19334) by Vova Kolmakov · 6 days ago
  29. a18f221 [HUDI-18060] Improve error message when ordering field value is null (#18061) by Prashant Wason · 6 days ago
  30. 0acf20f refactor(spark): share the Spark 3.x legacy parquet file format via a common base (#19341) by Y Ethan Guo · 6 days ago
  31. 55becc7 fix: do not fall back to timeline server markers on transient HDFS failures (#18887) by vamshipasunuru1 · 6 days ago
  32. 7f786d4 chore: upload Flink integration-test coverage (#19343) by Danny Chan · 6 days ago
  33. 58dd532 fix(hive-sync): set HMS table createTime in seconds instead of milliseconds (#19335) by Vova Kolmakov · 6 days ago
  34. d8ebba4 fix: relax existing column to nullable in reconcileSchema when source made it nullable (#19337) by vamsikarnika · 6 days ago
  35. cc75051 fix(hive-sync): fix partition-value parsing on '=' and pushdown comparator overflow (#19336) by Vova Kolmakov · 7 days ago
  36. b90627a test(common): add unit coverage for metrics reporters and schema utilities (#19221) by Y Ethan Guo · 7 days ago
  37. 41a8fc8 fix(mdt): use native log format for file group initialization (#19312) by Shuo Cheng · 7 days ago
  38. d78a7b5 fix(flink): avoid reusing split reader functions across fetchers (#19315) by Shuo Cheng · 7 days ago
  39. afec0c9 fix(hive-sync): close proxied IMetaStoreClient in HoodieHiveSyncClient.close() to prevent HMS connection leak (#19331) by Shihuan Liu · 7 days ago
  40. f558c00 test(client): add unit coverage for client utilities and services (#19222) by Y Ethan Guo · 8 days ago
  41. bd2888c test(common): add unit coverage for config and utility classes (#19220) by Y Ethan Guo · 8 days ago
  42. 93f2d4c test(spark): add unit coverage for Spark row, schema and sort utilities (#19219) by Y Ethan Guo · 8 days ago
  43. 59ed745 fix(hive-sync): sync column and partition column comments to HMS (#19289) by Ranga Reddy · 8 days ago
  44. 5178a3b fix(metadata-table): add config to skip zero-size data files on MDT initialization (#18611) by Nada · 9 days ago
  45. 4394513 test(common): add log-format reader and scanner coverage (#19223) by Y Ethan Guo · 9 days ago
  46. a806d39 [HUDI-8970] Change scheduleandexecute in RunCompactionProcedure to compact all pending plans too (#12794) by voonhous · 10 days ago
  47. 5f7f766 fix(test): stabilize flaky testReattemptOfFailedClusteringCommit (#19120) by Lokesh Jain · 11 days ago
  48. d8b7525 fix(ci): let validate-source's RAT check fail on unlicensed files outside Maven modules (#19275) by Vova Kolmakov · 11 days ago
  49. f659030 fix: fix the file size calibration for native log format (#19293) by Danny Chan · 11 days ago
  50. 79908ef docs: claim RFC-108 Multi-dataset incremental reads in Hudi Streamer (#19308) by ashokkumar-allu · 11 days ago
  51. d10b868 fix(flink): remove the Source V2 read teardown race via materialized bounded minibatches (#19202) by Vova Kolmakov · 11 days ago
  52. 4422610 refactor(common): utils consolidation sweep remnants (#19284) by vinoth chandar · 11 days ago
  53. 89da960 docs: claim RFC-109 Hudi Native Vector Index (#19303) by chrevanthreddy · 12 days ago
  54. e098da7 fix(ci): make the source-release binary-file check actually run (#19267) by Vova Kolmakov · 13 days ago
  55. b0a2563 fix(build): declare lombok in annotationProcessorPaths to deflake parallel-build compilation (#19020) by Vova Kolmakov · 13 days ago
  56. 6543aec feat(lance): enable lance as native log format (#19283) by Shuo Cheng · 13 days ago
  57. 59e62dd fix: Improve error message for conflict resolution (#18119) by Vinish Reddy · 13 days ago
  58. 502f0ce docs(rfc): [HUDI-9315] Mark RFC-94 (Timeline UI) as IN PROGRESS (#19294) by voonhous · 13 days ago
  59. ac179e4 feat(spark): Support data skipping based on partitioned RLI (#19013) by Shuo Cheng · 13 days ago
  60. 1dfbdcb fix: reuse Inflater/Deflater in BitCaskDiskMap to avoid JDK8 finalizer contention (#18818) by vamsikarnika · 14 days ago
  61. 29a4925 feat(flink): support nested data type for flink lance reader/writer (#19242) by Shuo Cheng · 2 weeks ago
  62. 43b2926 feat(tools): add TimelineInspector standalone Java tool for timeline forensics (#19238) by Sivabalan Narayanan · 2 weeks ago
  63. 2bed01a refactor(common): consolidate *Utils classes (dead code, fold-ins, renames, dedup) (#19212) by vinoth chandar · 2 weeks ago
  64. 72c9558 [MINOR] Add restore action in all commits timeline (#19277) by Trivedhi · 2 weeks ago
  65. a4cde3a test(spark): cover the legacy parquet read path with file-group reader disabled (#19133) by Y Ethan Guo · 2 weeks ago
  66. 770e8aa fix(spark): match the staged table, not LogicalWriteInfo, in BasicStagedTable.newWriteBuilder (#19251) by Vova Kolmakov · 2 weeks ago
  67. 014358a [HUDI-18075] Cap files per batch in cloud incremental source (#18076) by Lokesh Jain · 2 weeks ago
  68. 2a5c83b feat(ui): [HUDI-9315] Add RFC-94: Hudi Timeline UI (#13152) by voonhous · 2 weeks ago
  69. bbe73d3 fix: align log4j2 and slf4j versions to resolve IntelliJ test failures (#18177) by Surya Prasanna · 2 weeks ago
  70. 7854419 fix(writer): skip unsupported native log column stats metadata (#19245) by Shuo Cheng · 2 weeks ago
  71. 541ab01 Remove spaces around partition columns (#18423) by Lin Liu · 2 weeks ago
  72. 1e2736f fix(ci): retry transient Maven Central 5xx and stop seeding a 10 MB Maven cache (#19244) by Vova Kolmakov · 2 weeks ago
  73. 120d73f fix(spark): read INLINE blobs as CONTENT on internal write-side Lance… (#19236) by voonhous · 2 weeks ago
  74. be8a54c fix(flink): prevent data loss on global failover for streaming writes (#19237) by Joy · 2 weeks ago
  75. 7b843ae refactor(spark): consolidate the vendored 3.x Avro serde forks into hudi-spark3-common (#19168) by Y Ethan Guo · 3 weeks ago
  76. bc87477 fix(common): name the offending expression in BindVisitor's unsupported-predicate error (#19241) by Vova Kolmakov · 3 weeks ago
  77. 14fe739 fix(spark): read Lance BLOB columns in <=512-row chunks to avoid lance-core FFI abort (#19181) by vinoth chandar · 3 weeks ago
  78. b22a3d7 test(spark): add extended SQL parser coverage for index DDL and Hudi column types (#19218) by Y Ethan Guo · 3 weeks ago
  79. 9df73c7 fix(bundle): shade parquet-variant into common bundle includes for Spark 4.1+ (#19235) by voonhous · 3 weeks ago
  80. 6fa8461 fix(ci): cap UT_FT_10 reactor install to -T 1 to avoid GCLocker-induced compile OOM (#19119) by Vova Kolmakov · 3 weeks ago
  81. 1046ec0 test(integ-test): add Spark 4.1.1 stack to hive-sync E2E matrix (#19216) by voonhous · 3 weeks ago
  82. 0fc240b test: add Vortex reader/writer round-trip test (#19182) by Y Ethan Guo · 3 weeks ago
  83. 21a9315 test(client): cover low-coverage small classes across hudi-client (#19224) by Y Ethan Guo · 3 weeks ago
  84. 1165eb53 fix(spark): demote spurious per-write INFO logs to debug (#19170) by Y Ethan Guo · 3 weeks ago
  85. c18b366 docs: update javadoc spark-submit examples to Spark 3.5 / Scala 2.12 (#19171) by Y Ethan Guo · 3 weeks ago
  86. 2baa29b feat(index): Refactor metadata table update logic based on index abstraction (#18372) by Shuo Cheng · 3 weeks ago
  87. 3015eb9 test(integ-test): add Testcontainers E2E for VECTOR/BLOB/VARIANT Hive… (#19203) by voonhous · 3 weeks ago
  88. c56cca6 feat: add FileNameParser for file name decoding (#19198) by Danny Chan · 3 weeks ago
  89. a001ea8 feat(index): Add Indexer abstraction and refactor metadata table init… (#18348) by Shuo Cheng · 3 weeks ago
  90. b84f618 fix(reader): Remove redundant partition value conversion in RecordContext (#19201) by Shuo Cheng · 3 weeks ago
  91. ee3692c fix(flink): avoid AIOOBE in NestedColumnReader across the read batch boundary (#19210) by ericyuan915 · 3 weeks ago
  92. a1dbb56 feat: Support table version 10 to 9 downgrade (#19199) by Shuo Cheng · 3 weeks ago
  93. aefabf7 test(trino): de-flake testRecordLevelFileSkipping by setting the record-index wait timeout (#19213) by Vova Kolmakov · 3 weeks ago
  94. cf2566c feat: Support insert-order record positions for native log files (#19200) by Shuo Cheng · 3 weeks ago
  95. d291efc refactor(common)!: continue hudi-common core/common package reorganization (#19195) by vinoth chandar · 3 weeks ago
  96. 8a65383 feat(writer): Switch default to native log format for table version >= 10 (#19118) by Shuo Cheng · 3 weeks ago
  97. 3cc8fd1 refactor(common)!: reorganize hudi-common packages into core and common namespaces (#19193) by vinoth chandar · 3 weeks ago
  98. 0d76076 refactor(client)!: reorganize hudi-client-common internal package layout (#19192) by vinoth chandar · 3 weeks ago
  99. feea94b refactor(flink): migrate hand-declared LOG to Lombok @Slf4j (#19190) by voonhous · 3 weeks ago
  100. 2ab2c0a refactor(io): use SLF4J parameterized logging instead of string concatenation (#19188) by voonhous · 3 weeks ago