Google Git
Sign in
apache/hudi/HEAD
  1. 0972489 fix: support reading tables partitioned on a nested column (#19123) by Vinish Reddy · 4 hours ago master
  2. bbb2a3a fix(lock): stop guarding the filesystem lock with an interned string literal and make the provider serializable (#19486) by Ranga Reddy · 12 hours ago
  3. 2c14ff2 fix(spark): align libthrift with the Hive 2.3.10 client jars (#19682) by voonhous · 22 hours ago
  4. ee093f0 fix(spark): make new schema evolution fields nullable (#19665) by Danny Chan · 25 hours ago
  5. 0b1c0e0 test(spark): make sync_validate fail-fast pins independent of libthrift resolution (#19681) by voonhous · 26 hours ago
  6. 287ea4f feat(spark): support standard writes and compaction for LSM tables (#19576) by Shuo Cheng · 27 hours ago
  7. 57f0b81 fix(spark): don't prune files with unknown null-count on IS NULL (#19646) by Sepuri Sai Krishna · 27 hours ago
  8. 6ef0c90 test(writer): cover legacy populate.meta.fields persistence on table version 6 (#19695) by Y Ethan Guo · 27 hours ago
  9. 5a11a4f fix(storage-format): ignore temporary LSM timeline manifests (#19659) by Danny Chan · 3 days ago
  10. 82640e5 feat(cli): add table set-meta-fields-mode command (#19206) by Sivabalan Narayanan · 3 days ago
  11. a5251b3 feat(writer): add hoodie.meta.fields.mode for selective meta-field population on CoW tables (#19205) by Sivabalan Narayanan · 3 days ago
  12. a08988a fix(flink): disable native log rollover within mini-batch (#19656) by Shuo Cheng · 3 days ago
  13. 697bfe1 fix(flink): sort ClientIds heartbeat files numerically instead of lexicographically (#19653) by Aditya Nikam · 3 days ago
  14. 42e885f feat(kinesis): Cross-account Kinesis source support via STS assume-role in JsonKinesisSource (#19383) by Surya Dhaneshwar · 4 days ago
  15. e8ca8df fix(spark): return partition values in Catalyst's internal representation (#19652) by Sepuri Sai Krishna · 4 days ago
  16. 989badc fix(common): normalize hudi table base path in implicit-key lock providers (#18814) by Davis-Zhang-Onehouse · 4 days ago
  17. 541ed1c feat(trino): track trinodb/trino master via a pinned SHA (#19642) by voonhous · 5 days ago
  18. 3f744ea feat(core): Pass the number of updates from workload profiling through to merge handle (#18396) by Y Ethan Guo · 5 days ago
  19. 08eb2d9 fix: Parallelize cloud object existence checks in S3EventsHoodieIncrSource (#18252) by Vinish Reddy · 5 days ago
  20. b6c4677 feat: Add source path field in table created from S3/GCS source (#14257) by Roushan Kumar · 5 days ago
  21. 576e5b6 fix(avro): detect the two-field shredded variant shape and harden the variant merge path (#19620) by voonhous · 5 days ago
  22. 558007d test(spark): add stored procedure coverage (#19161) by Y Ethan Guo · 8 days ago
  23. a5b2403 fix(core): decode strings read from storage as UTF-8 (#19454) by Lin Liu · 8 days ago
  24. 26c0c08 fix(build): stop hudi-presto-bundle depending on another bundle (#19490) by Ranga Reddy · 8 days ago
  25. acbe341 fix(test): cover SparkContext shutdown path in HoodieMetadataTableValidator (#19349) by Lokesh Jain · 8 days ago
  26. c6662e7 test(spark): stop skipping TestPartitionBucketIndexSupport on Spark 4 (#19471) by deepakpanda93 · 8 days ago
  27. bd98a49 test(flink): stabilize Sink V2 UID assertion (#19623) by Danny Chan · 8 days ago
  28. 37ac38e docs: rfc-107 Support data partition aware RocksDB RecordIndexBackend (#19046) by Peter Huang · 8 days ago
  29. d35e16f chore(deps): bump org.apache.logging.log4j:log4j-api (#19628) by dependabot[bot] · 8 days ago
  30. 12a58eb Fetch avro version from pom.properties to fix NPE (#19596) by Trivedhi · 8 days ago
  31. e1dd86e fix(avro): detect shredded variant base files by shape so reconstruct… (#19582) by voonhous · 9 days ago
  32. b1639e0 fix(spark): read shredded variants through the CDC and legacy streaming paths, and restore partition values there (#19583) by voonhous · 9 days ago
  33. 91f3869 refactor(flink): simplify streaming write pipeline construction (#19579) by Danny Chan · 9 days ago
  34. 61fb2f6 docs: claim RFC-110 native full-text search (#19614) by Danny Chan · 9 days ago
  35. b2174b6 feat(hive-sync): parallelize DROP partitions in HiveQL sync mode (#19033) by Sivabalan Narayanan · 10 days ago
  36. 3ba31dd fix(spark): read shredded variants through internal write-side parquet reads (#19558) by voonhous · 11 days ago
  37. 888f6ec fix(storage-format): fix multi-block previous-block offset and add byte-level HFile writer tests (#19083) by Y Ethan Guo · 11 days ago
  38. 3988053 fix(storage-format): emit HBase-readable block-index keys in the native HFile writer (#19071) by Y Ethan Guo · 11 days ago
  39. dfc2106 fix(flink): use UTF-8 ordering for LSM record keys (#19548) by Shuo Cheng · 11 days ago
  40. 260ee6b test(common): improve ORC and filesystem utility coverage (#19542) by Shuo Cheng · 11 days ago
  41. 92f9640 test(flink): improve coverage for utility classes (#19546) by Shuo Cheng · 11 days ago
  42. 4853b57 fix: harden async indexing and improve coverage (#19537) by Danny Chan · 12 days ago
  43. f3806cb test(flink): improve pipeline and utility test coverage (#19540) by Shuo Cheng · 12 days ago
  44. 65cf7e8 test: improve meta sync coverage (#19539) by Danny Chan · 2 weeks ago
  45. a2bdd5b test(flink): add sink v2 operator coverage (#19543) by Danny Chan · 2 weeks ago
  46. 49fade8 feat(spark): enable format-aware sort ordering and LSM reading for Spark (#19502) by Shuo Cheng · 2 weeks ago
  47. 2490309 perf(flink): use a shared work-stealing split pool for Source V2 bounded reads (#19520) by ericyuan915 · 2 weeks ago
  48. b88f235 feat(common): query LAYOUT_VERSION_1 timelines in CompletionTimeQueryView by using instant time as completion time (#19338) by fhan · 2 weeks ago
  49. 79fedcf fix(client): report completed timeline action in clustering callback (#19464) by Sagar Sumit · 2 weeks ago
  50. 0425c5c fix(flink): preserve Avro fixed decimal widths in Parquet writes (#19522) by Shuo Cheng · 2 weeks ago
  51. c4b3893 fix(metrics): route the reflection failures a CloudWatch skew actually produces (#19477) by Ranga Reddy · 2 weeks ago
  52. d8dc1f0 test: add unit test coverage for secondary index, expression, and bloom filter classes in hudi-common (#19204) by Rahil C · 2 weeks ago
  53. 9a30ecd fix(spark): preserve the Avro fixed-size decimal width in the Spark row write support (#19512) by Y Ethan Guo · 2 weeks ago
  54. a44572b fix(flink): close lookup reader after cache reload attempts (#19503) by Danny Chan · 2 weeks ago
  55. 0db5246 test(trino): add a Trino E2E testcontainers pipeline for the RFC-105 connector (#19217) by voonhous · 2 weeks ago
  56. 4a9cef8 chore(ci): trim the CI matrix and reset required checks to unblock PRs (#19514) by Y Ethan Guo · 2 weeks ago
  57. 1aac63c chore(ci): stop requiring GitHub checks on master to unblock PRs (#19523) by Y Ethan Guo · 2 weeks ago
  58. c63c9bf fix(metrics): do not drop the whole CloudWatch batch on one unmappable metric name (#19476) by Ranga Reddy · 3 weeks ago
  59. f41e8e3 fix(flink): close CDC image spillable maps on failures (#19482) by Danny Chan · 3 weeks ago
  60. 1f8e53a test: Coverage clustering merge bootstrap (#19493) by voonhous · 3 weeks ago
  61. c2e884a perf(trino): drop the decimal schema cache and memoize prefilled values (#19495) by voonhous · 3 weeks ago
  62. 66b9c6e fix(trino): report real block size and slice splits solely by target_split_size (#19478) by voonhous · 3 weeks ago
  63. e4718be fix(schema): require a per-field override to promote a bare long to a timestamp logical type (#19384) by Y Ethan Guo · 3 weeks ago
  64. 70a5a4d fix(fs): stop depending on the optional FileSystem#getScheme() (#19470) by Ranga Reddy · 3 weeks ago
  65. 99ceae1 fix(meta-sync): advance last commit time synced when it trails the active timeline midpoint (#19239) by Y Ethan Guo · 3 weeks ago
  66. 2f8a725 perf(trino): cache decimal Avro schema in HudiAvroSerializer instead … (#19483) by voonhous · 3 weeks ago
  67. 55c7a30 fix(timeline): do not NPE on archived instants without a completion time (#19452) by Ranga Reddy · 3 weeks ago
  68. 637996c fix(metrics): explain how to enable the CloudWatch reporter when hudi-aws is absent (#19418) by Ranga Reddy · 3 weeks ago
  69. d98f2f1 refactor(spark): remove dead HoodieNestedSchemaPruning rule (#19458) by voonhous · 3 weeks ago
  70. 636e6fa test(java-client): cover both marker types with the embedded timeline server (#19444) by Ranga Reddy · 3 weeks ago
  71. b65bc18 fix(build): make submodule builds find the checkstyle import-control file (#19420) by Ranga Reddy · 3 weeks ago
  72. 365d0e4 fix(spark): throw proper ParseExceptions in the six extended SQL AST... (#19460) by voonhous · 3 weeks ago
  73. d7d00ab fix(build): publish dependency-reduced POMs for shaded bundles (#19433) by Ranga Reddy · 3 weeks ago
  74. 3160670 fix(build): exclude nested .mvn directories from the RAT check (#19462) by Vova Kolmakov · 3 weeks ago
  75. 64afac0 fix(trino): remap pushed-down predicate columns to physical file ordinals (#19456) by Vova Kolmakov · 3 weeks ago
  76. f8c6dd8 chore(spark): prune dead code in the six extended SQL AST builders (#19455) by voonhous · 3 weeks ago
  77. 07a6635 fix(flink): rethrow StreamWriteOperatorCoordinator start() failures (#19432) by Joy · 3 weeks ago
  78. 6894f0c fix(trino): read uncompacted MDT HFILE log deltas and guard index pruning (#19298) by voonhous · 3 weeks ago
  79. 9d32b3d fix(streamer): write non-partitioned sample-writes table for record-size estimation (#19115) by Y Ethan Guo · 3 weeks ago
  80. 79e6b18 test(spark): enhance blob/vector SQL DDL coverage of the extended parser (#19408) by Y Ethan Guo · 3 weeks ago
  81. 466929b test(spark): add nested schema pruning coverage (#19406) by Y Ethan Guo · 3 weeks ago
  82. 1ba9a58 test(spark): tail-sweep coverage for low-coverage datasource classes (#19405) by Y Ethan Guo · 3 weeks ago
  83. c9dbde0 test(spark): add incremental read-path relation coverage (#19404) by Y Ethan Guo · 3 weeks ago
  84. c815c3f test(spark): extend Spark 4 variant shredding coverage (#19403) by Y Ethan Guo · 3 weeks ago
  85. 8c44ce5 test(spark): add HiveSyncProcedure coverage (#19407) by Y Ethan Guo · 3 weeks ago
  86. 3e08b72 test(utilities): Tail sweep: low-coverage small classes for hudi-utilities (#19416) by voonhous · 3 weeks ago
  87. f9c19c0 test(metadata): fix testReattemptOfFailedClusteringCommit to simulate the crash before any metadata read (#19434) by Y Ethan Guo · 3 weeks ago
  88. baf830c fix(ci): stop docker-java17-test from sealing a near-empty Maven cache (#19441) by Vova Kolmakov · 3 weeks ago
  89. 29b42cb refactor(reader): seal the shared merge path in KeyBasedFileGroupRecordBuffer (#19415) by Ranga Reddy · 3 weeks ago
  90. 66e94ab perf(ingest): parallelize SQS receive and delete in the S3 events source (#19396) by Davis-Zhang-Onehouse · 3 weeks ago
  91. 133a255 fix(utilities): include metadata table index-init instants in the record index validation snapshot (#19395) by Davis-Zhang-Onehouse · 3 weeks ago
  92. 8ee40b4 fix(hive-sync): make skip_ro_suffix take precedence over sync_snapshot_with_table_name (#19427) by Y Ethan Guo · 3 weeks ago
  93. cb0f9b1 feat(hive-sync): add config to force-recreate the metastore table on every sync (#19426) by Y Ethan Guo · 3 weeks ago
  94. 377fc04 perf(common): avoid UTF-8 allocations in string comparator (#19414) by Shuo Cheng · 3 weeks ago
  95. fcc92bc1 docs(flink): list glue as a valid hive_sync.mode (#19435) by Ranga Reddy · 3 weeks ago
  96. bf3cc43 feat(client): enrich write commit callback message and fire it for table-service commits (#18988) by Sagar Sumit · 3 weeks ago
  97. b38855ff feat(flink): Sort bulk insert records by record key for LSM layout (#19390) by Shuo Cheng · 3 weeks ago
  98. e37bfb5e fix(ci): retry the jacoco download when Maven Central returns 429 (#19430) by Vova Kolmakov · 3 weeks ago
  99. 633d142 test(trino): add MoR read tests for delete markers, custom payloads and commit-time ordering (#19295) by voonhous · 3 weeks ago
  100. d43cc5c feat(release): add a JDK 25 staging path for org.apache.hudi:hudi-trino (#19410) by voonhous · 3 weeks ago