Google GitGoogle Git
Sign in
apache/hudi/HEAD
  1. 1d3a0af fix(common): anchor a file group's first slice on a committed log (#19785) by zhaoyudi-creator · 7 hours ago master
  2. a46909b fix: close InflaterInputStream in HoodieAvroDataBlock.decompress() to prevent native memory leak (#19861) by Venkateswarlu Boggavarapu · 11 hours ago
  3. 11527ae fix(flink): bootstrap operator for bounded source (#19844) by Peter Huang · 11 hours ago
  4. 44b7ed3 chore(ci): align Codecov range with 80% target (#19896) by voonhous · 20 hours ago
  5. 648996f feat(agent): add Hudi Architect design-time skill (#19380) by Sivabalan Narayanan · 21 hours ago
  6. 8af07e1 fix(utilities): validator Config.equals and drop-partitions hive sync, with tests for the standalone tools (#19875) by voonhous · 28 hours ago
  7. 6341107 test(cli): cover timeline, export, metadata commands and the SparkMain helpers (#19877) by voonhous · 28 hours ago
  8. 4be4864 chore(docker): move demo/IT images to Spark 3.5.9 (#19888) by voonhous · 29 hours ago
  9. 9685817 docs(flink): document Lance runtime dependencies (#19866) by Shuo Cheng · 29 hours ago
  10. 91f32af test(aws): cover the Glue sync client, DynamoTableUtils and HoodieAWSConfig (#19876) by voonhous · 32 hours ago
  11. e6b8ef6 fix(core): use incoming record keys in native log writers (#19874) by Danny Chan · 32 hours ago
  12. 58c9e64 chore(spark): bump Spark 3.5 to 3.5.9 and fast-path the CI download (#19884) by voonhous · 33 hours ago
  13. 4c6e75b Fix truncated return type in RFC-101 sample and typos across docs (#19885) by Toyeshh Medikonda · 35 hours ago
  14. eccfee6 docs(rfc): RFC-109 native vector search support in Apache Hudi (#19309) by chrevanthreddy · 2 days ago
  15. 7b4ad9d fix(common): scan jar entries in ReflectionUtils#getTopLevelClassesInClasspath (#19624) by deepakpanda93 · 2 days ago
  16. bb6f52c feat(timeline-ui): [HUDI-9315] Add Hudi Timeline UI (#13147) by voonhous · 2 days ago
  17. 6ac2790 test(clustering): re-enable testClusteringPlanInflight and fix its timeline transition (#19865) by Ranga Reddy · 2 days ago
  18. 64904e8 fix(flink): repair test compilation after metadata field mode migration (#19873) by Danny Chan · 2 days ago
  19. eccbef9 feat(flink): support metadata field modes for COW tables (#19858) by Danny Chan · 2 days ago
  20. 56eae7b test(utilities): report why the continuous-mode wait timed out (#19485) by Ranga Reddy · 3 days ago
  21. 08af586 fix(cli): repair the hudi-cli tests and re-enable the module in CI (#18816) by Kavya Popat · 3 days ago
  22. cc9de4d fix(schema): stop union walks looping forever (#19834) by voonhous · 3 days ago
  23. 7567809 fix(lock): fix lock config derivation for Spark procedure (#19794) by Joy · 3 days ago
  24. 8a41388 fix(trino): keep none() when splitting predicates (#19863) by voonhous · 3 days ago
  25. d9e6f42 feat(flink): support vector columns in Lance reader (#19842) by Shuo Cheng · 3 days ago
  26. 6c666ee [HUDI-736] Simplify ReflectionUtils#getTopLevelClassesInClasspath (#19784) by LeonxLJX · 3 days ago
  27. cebbd6a fix(spark): widen procedure filter numeric comparisons (#19836) by Nikulin Nikita · 4 days ago
  28. 73e6872 refactor(spark): collapse HoodieTableState (#19849) by Ryu · 4 days ago
  29. 9903b6d feat(flink): support record index handling in dynamic bucket assign function (#19837) by Peter Huang · 4 days ago
  30. d36c1ab fix(build): remove redundant hadoop mr bundle dependencies (#19856) by hutiefang76 · 4 days ago
  31. b71b10b fix(spark): reject unsupported procedure filter functions (#19850) by Ryu · 5 days ago
  32. 7e518bc docs: claim RFC-111 non-blocking updates during clustering (#19851) by Sagar Sumit · 5 days ago
  33. a7deb61f fix(schema): lowercase projected names with Locale.ROOT (#19835) by voonhous · 6 days ago
  34. aeaa775 fix(hive-sync): close the SessionState HiveQL sync starts (#19812) by Shihuan Liu · 7 days ago
  35. e29d4d6 chore(deps): bump org.apache.thrift:libthrift (#19824) by dependabot[bot] · 7 days ago
  36. 9b5742c refactor(schema): dissolve AvroSchemaUtils, dedupe compat (#19810) by voonhous · 7 days ago
  37. b290301 refactor(config): deprecate hoodie.parquet.outputtimestamptype; no-op since 1.1.0 (#19815) by Ranga Reddy · 7 days ago
  38. 5e58dd3 feat(flink): support vector columns in Lance writer (#19831) by Shuo Cheng · 7 days ago
  39. 40a41c9 feat(storage): support separate zstd level for native parquet logs (#19781) by Shuo Cheng · 7 days ago
  40. d9e08f0 feat(flink): add partitioned rli boostrap operator (#19805) by Peter Huang · 8 days ago
  41. 93f1f71 refactor(schema): schema util contracts, dead API and folds (#19809) by voonhous · 8 days ago
  42. 7a3e2f3 fix(tests): reach TFramedTransport at the package libthrift 0.14 moved it to (#19830) by Y Ethan Guo · 8 days ago
  43. 72989b4 fix(flink): run mapGroupsByKey in dedicated fork join pool (#19819) by Shuo Cheng · 8 days ago
  44. 31904ac fix(build): exclude bundled Avro from the DataHub sync bundle (#19814) by Y Ethan Guo · 9 days ago
  45. ef83418 feat(variant): infer shredding schemas by default on Spark 4.1+ (#19808) by voonhous · 9 days ago
  46. a2788ee fix(spark-sql): resolve MERGE INTO partition columns so records are not mis-partitioned (#19610) by Lin Liu · 9 days ago
  47. ca28fdb chore(trino): advance trino master pin to 40b70400a8a6 (#19807) by voonhous · 10 days ago
  48. c59987a fix(variant): project PushVariantIntoScan struct paths in the ... (#19783) by voonhous · 10 days ago
  49. 1e59c9e fix(core): record the ordering field when upgrading a table from version 1 (#19803) by Y Ethan Guo · 10 days ago
  50. 886ebc7 fix(build): tidy shade config drift ahead of hoisting the POM flags (#19492) by Ranga Reddy · 11 days ago
  51. 0db4d3a fix(common): prevent multi-table commits failing with metrics enabled (#19787) by Stefan Wang · 11 days ago
  52. 6103a52 fix(variant): shred nested variants on the Avro write path for parity… (#19777) by voonhous · 11 days ago
  53. 6db0dde fix(spark): handle empty projections with internal schema (#19796) by hutiefang76 · 11 days ago
  54. 1593524 fix(hadoop-mr): ignore blank Hive projection ids and report both lists on mismatch (#19463) by Ranga Reddy · 12 days ago
  55. 8e88496 fix(spark): keep the embedded Derby metastore out of the RAT check (#19792) by voonhous · 13 days ago
  56. 6fd8096 fix(spark): make SparkCatalogMetaStoreClient sync-safe and cover the Spark catalog DDL paths (#19162) by Y Ethan Guo · 13 days ago
  57. 01935d1 fix(spark): restore the java.util.Map import in TestDataSourceUtils (#19789) by Rahil C · 14 days ago
  58. 1112c37 feat(metrics): report record index lookup counters to the metrics reporter (#19575) by Rahil C · 14 days ago
  59. 9db33ba test(core): add file format dispatch exhaustiveness coverage (#19253) by Y Ethan Guo · 14 days ago
  60. 6b5ea33 feat(storage): default parquet codec to zstd for flink and spark 3.5+ (#19685) by Shuo Cheng · 14 days ago
  61. 816bd96 test(spark): cover schema-on-read evolution reads through the file-group reader (#19165) by Y Ethan Guo · 14 days ago
  62. 7b377a5 test(spark): cover low-coverage small classes in spark datasource (#19164) by Y Ethan Guo · 2 weeks ago
  63. efe02e1 fix(variant): close the shredded-read gaps exposed by a mixed-layout test matrix (#19687) by voonhous · 2 weeks ago
  64. 3a3a32f docs(hudi-notebooks): note S3A works with any S3-compatible object store (#19423) by Gonzalo Peña-Castellanos · 2 weeks ago
  65. 452b237 fix(lock): name the cause on FAILED_TO_RELEASE in StorageBasedLockProvider (#19574) by Praveen Gajulapalli · 2 weeks ago
  66. 2d73fe4 feat(spark): support bucket index for LSM tables (#19727) by Shuo Cheng · 2 weeks ago
  67. a0d4670 fix: close JDBC connection in UtilHelpers.getJDBCSchema to prevent connection leak (#19772) by Venkateswarlu Boggavarapu · 2 weeks ago
  68. 863f84a fix(sync): drop the duplicate UpdateTable in updateTableSchema (#19762) by niranjan-1408 · 2 weeks ago
  69. d4f9eb9 refactor(variant): self-align log-block variant rows, drop buffer-level projection hook (#18923) by voonhous · 2 weeks ago
  70. 1895de8 perf(flink): preempt inactive write buckets on memory exhaustion (#19728) by fhan · 2 weeks ago
  71. fe82430 fix(sync): keep each partition's recorded location when cascading Glue schema changes (#19761) by niranjan-1408 · 2 weeks ago
  72. 87778de fix(streamer): Include start commit in S3/GCS IncrSource incremental query (#18949) by Y Ethan Guo · 2 weeks ago
  73. 85033e3 test(spark): add write and commit path coverage (#19163) by Y Ethan Guo · 2 weeks ago
  74. 3eef646 fix(hive): read the skeleton file when a bootstrap query projects no columns (#19510) by Ranga Reddy · 2 weeks ago
  75. 98c61ed test(utilities): cover the KafkaAvroSchemaDeserializer schema-refresh... (#19760) by voonhous · 2 weeks ago
  76. 0c3f00e fix(trino): read LSM archived-timeline parquet files through a Trino-… (#19732) by voonhous · 2 weeks ago
  77. d43fa7f fix(debezium): backfill Postgres TOAST columns on a copy so the merge result survives (#19749) by Lokesh Jain · 2 weeks ago
  78. 18ae8c3 feat(flink): Extend RocksDBDAO with generic column-family lifecycle operations (#19744) by Peter Huang · 2 weeks ago
  79. 3ddf628 fix(timeline-service): support response charset for Timeline Server interaction (#19753) by Lokesh Jain · 2 weeks ago
  80. b5263e1 fix(client): create a new log file version instead of reopening the latest on pre-v8 writes (#19755) by Lokesh Jain · 2 weeks ago
  81. ad221c4 fix(common): escape dots in single-level hive-style partition column names (#19751) by Lokesh Jain · 2 weeks ago
  82. 34b4850 fix(streamer): route configured write table version into sample-writes flow (#19746) by Lokesh Jain · 2 weeks ago
  83. c28a87d fix(storage): resolve HoodieStorage from a path instead of a default local URI (#19737) by Y Ethan Guo · 2 weeks ago
  84. bcaf2d4 chore(docker): address PR #18520 review comments for Spark 4.0.1 stack (#18524) by voonhous · 2 weeks ago
  85. a27828d test(io): drive the HFile writer tests through byte arrays instead of a file (#19618) by Ranga Reddy · 2 weeks ago
  86. 29b7a52 fix(trino): skip predicate pushdown on type-evolved parquet columns (#19467) by Vova Kolmakov · 2 weeks ago
  87. 39c510d fix: ensure AmazonDynamoDBLockClient is always closed in DynamoDBBasedLockProviderBase.close() (#19742) by Venkateswarlu Boggavarapu · 2 weeks ago
  88. fe716f1 fix: ensure CuratorFramework is always closed in BaseZookeeperBasedLockProvider.close() (#19741) by Venkateswarlu Boggavarapu · 2 weeks ago
  89. e3ee960 feat(flink): add RocksDB partitioned RLI Cache Flink Options (#19641) by Peter Huang · 2 weeks ago
  90. 6cd1196 fix(spark): make partition DDL commands honor slash separated date partitioning (#19703) by Sepuri Sai Krishna · 2 weeks ago
  91. 6aa6a86 fix(core): resolve rollback storage from the partition path, not the default URI (#19735) by Vinish Reddy · 2 weeks ago
  92. 1c573f8 fix(utilities): use endOffsets when no offset is greater than the checkpoint timestamp (#19658) by wangxianghu · 2 weeks ago
  93. 1ca682c docs(hudi-io): fill in the HFile format details the doc was missing (#19721) by Ranga Reddy · 2 weeks ago
  94. ef07f0f feat(flink): support Flink 2.2 (#19655) by Shuo Cheng · 2 weeks ago
  95. 3affaf7 fix(hive-sync): pass the default partition through the slash-encoded value extractors (#19710) by Sepuri Sai Krishna · 2 weeks ago
  96. 476b335 feat(variant): auto-infer per-file variant shredding schemas on shredding inference (#18961) by voonhous · 2 weeks ago
  97. 2315459 fix(spark-sql): resolve a partition path without validating the record key (#19709) by Lin Liu · 2 weeks ago
  98. e0fe585 fix(hive-sync): call Driver.destroy() so HiveQL sync stops leaking Drivers into ShutdownHookManager (#19718) by Shihuan Liu · 2 weeks ago
  99. 81fd499 fix(flink): prevent reusing diverged buffers on memory exhaustion (#19692) by fhan · 2 weeks ago
  100. 8adb095 chore(api): declare the unstructured ingestion SPIs evolving (#19701) by Rahil C · 3 weeks ago