commits  

Messages by Thread

• • Re: [PR] fix(flink): unwrap the list element type when creating vectors for nested arrays [hudi] via GitHub
  • Re: [PR] fix(flink): unwrap the list element type when creating vectors for nested arrays [hudi] via GitHub
  • Re: [PR] fix(flink): unwrap the list element type when creating vectors for nested arrays [hudi] via GitHub
  • Re: [PR] fix(flink): unwrap the list element type when creating vectors for nested arrays [hudi] via GitHub
  • Re: [PR] fix(flink): unwrap the list element type when creating vectors for nested arrays [hudi] via GitHub
  • Re: [PR] fix(flink): unwrap the list element type when creating vectors for nested arrays [hudi] via GitHub
• [PR] fix(utilities): Preserve _corrupt_record across transformers that drop it in ErrorTableAwareChainedTransformer [hudi] via GitHub
  • Re: [PR] fix(utilities): Preserve _corrupt_record across transformers that drop it in ErrorTableAwareChainedTransformer [hudi] via GitHub
  • Re: [PR] fix(utilities): Preserve _corrupt_record across transformers that drop it in ErrorTableAwareChainedTransformer [hudi] via GitHub
  • Re: [PR] fix(utilities): Re-add _corrupt_record when a transformer drops it in ErrorTableAwareChainedTransformer [hudi] via GitHub
  • Re: [PR] fix(utilities): Re-add _corrupt_record when a transformer drops it in ErrorTableAwareChainedTransformer [hudi] via GitHub
  • Re: [PR] fix(utilities): Re-add _corrupt_record when a transformer drops it in ErrorTableAwareChainedTransformer [hudi] via GitHub
  • Re: [PR] fix(utilities): Re-add _corrupt_record when a transformer drops it in ErrorTableAwareChainedTransformer [hudi] via GitHub
  • Re: [PR] fix(utilities): Re-add _corrupt_record when a transformer drops it in ErrorTableAwareChainedTransformer [hudi] via GitHub
• [I] [FEATURE] Recover table when hoodie.properties is corrupted or missing [hudi] via GitHub
• [PR] [HUDI] Add Delta Lake style VERSION AS OF time travel support [hudi] via GitHub
  • Re: [PR] [HUDI] Add Delta Lake style VERSION AS OF time travel support [hudi] via GitHub
  • Re: [PR] [HUDI] Add Delta Lake style VERSION AS OF time travel support [hudi] via GitHub
  • Re: [PR] [HUDI] Add Delta Lake style VERSION AS OF time travel support [hudi] via GitHub
  • Re: [PR] [HUDI] Add Delta Lake style VERSION AS OF time travel support [hudi] via GitHub
  • Re: [PR] [HUDI] Add Delta Lake style VERSION AS OF time travel support [hudi] via GitHub
  • Re: [PR] [HUDI] Add Delta Lake style VERSION AS OF time travel support [hudi] via GitHub
• [PR] feat(metadata)!: allow a files-partition entry to point outside the table base path [hudi] via GitHub
  • Re: [PR] feat(metadata)!: allow a files-partition entry to point outside the table base path [hudi] via GitHub
  • Re: [PR] feat(metadata)!: allow a files-partition entry to point outside the table base path [hudi] via GitHub
  • Re: [PR] feat(metadata)!: allow a files-partition entry to point outside the table base path [hudi] via GitHub
  • Re: [PR] feat(metadata)!: allow a files-partition entry to point outside the table base path [hudi] via GitHub
  • Re: [PR] feat(metadata)!: allow a files-partition entry to point outside the table base path [hudi] via GitHub
  • Re: [PR] feat(metadata)!: allow a files-partition entry to point outside the table base path [hudi] via GitHub
  • Re: [PR] feat(metadata)!: allow a files-partition entry to point outside the table base path [hudi] via GitHub
  • Re: [PR] feat(metadata)!: allow a files-partition entry to point outside the table base path [hudi] via GitHub
  • Re: [PR] feat(metadata)!: allow a files-partition entry to point outside the table base path [hudi] via GitHub
  • Re: [PR] feat(metadata)!: allow a files-partition entry to point outside the table base path [hudi] via GitHub
  • Re: [PR] feat(metadata)!: allow a files-partition entry to point outside the table base path [hudi] via GitHub
• [PR] fix(spark): read shredded variant leaves like Spark 4 [hudi] via GitHub
  • Re: [PR] fix(spark): read shredded variant leaves like Spark 4 [hudi] via GitHub
  • Re: [PR] fix(spark): read shredded variant leaves like Spark 4 [hudi] via GitHub
  • Re: [PR] fix(spark): read shredded variant leaves like Spark 4 [hudi] via GitHub
• (hudi) branch master updated: fix(flink): make the bucket pruning function serializable for source V2 (#20318) danny0405
• [I] Preserve delete payloads in Spark and Avro record reconstruction [hudi] via GitHub
• [PR] feat(gateway): add Spark Connect SQL backend [hudi] via GitHub
  • Re: [PR] feat(gateway): add Spark Connect SQL backend [hudi] via GitHub
• [PR] fix(spark): handle missing column statistics per conjunct [hudi] via GitHub
  • Re: [PR] fix(spark): retain matching files with missing column statistics [hudi] via GitHub
  • Re: [PR] fix(spark): retain matching files with missing column statistics [hudi] via GitHub
• (hudi) branch master updated: fix(spark): render decimal, date and timestamp values in CDC images (#20305) codope
• [PR] fix(spark): decline shredding into fixed leaves [hudi] via GitHub
  • Re: [PR] fix(spark): reject variant leaves Spark 4 cannot shred [hudi] via GitHub
  • Re: [PR] fix(spark): reject variant leaves Spark 4 cannot shred [hudi] via GitHub
  • Re: [PR] fix(spark): reject variant leaves Spark 4 cannot shred [hudi] via GitHub
  • Re: [PR] fix(spark): reject variant leaves Spark 4 cannot shred [hudi] via GitHub
  • Re: [PR] fix(spark): reject variant leaves Spark 4 cannot shred [hudi] via GitHub
  • Re: [PR] fix(spark): reject variant leaves Spark 4 cannot shred [hudi] via GitHub
• [I] [BUG] Log compaction rewrites record commit times; incremental reads re-emit old rows after cleaning (1.2.1) [hudi] via GitHub
• [PR] fix(flink): resend recovered write metadata on task retries [hudi] via GitHub
  • Re: [PR] fix(flink): resend recovered write metadata on task retries [hudi] via GitHub
  • Re: [PR] fix(flink): resend recovered write metadata on task retries [hudi] via GitHub
  • Re: [PR] fix(flink): resend recovered write metadata on task retries [hudi] via GitHub
  • Re: [PR] fix(flink): resend recovered write metadata on task retries [hudi] via GitHub
  • Re: [PR] fix(flink): resend recovered write metadata on task retries [hudi] via GitHub
  • Re: [PR] fix(flink): resend recovered write metadata on task retries [hudi] via GitHub
• (hudi) branch bot/trino-pin updated (5c6bebe35c3c -> e61e8b05e28f) github-bot
  • (hudi) 01/01: chore(trino): advance trino master pin to d3d4c7c0dfc3 github-bot
• [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
  • Re: [PR] fix(hfile): reject block sizes the HFile format cannot represent [hudi] via GitHub
• [I] Native HFile reader and writer do not reject block sizes the format cannot represent [hudi] via GitHub
  • Re: [I] Native HFile reader and writer do not reject block sizes the format cannot represent [hudi] via GitHub
  • Re: [I] Native HFile reader and writer do not reject block sizes the format cannot represent [hudi] via GitHub
• [PR] docs(hudi-io): document HFile offset and size widths and the non-root index block layout [hudi] via GitHub
  • Re: [PR] docs(hudi-io): document HFile offset and size widths and the non-root index block layout [hudi] via GitHub
  • Re: [PR] docs(hudi-io): document HFile offset and size widths and the non-root index block layout [hudi] via GitHub
  • Re: [PR] docs(hudi-io): document HFile offset and size widths and the non-root index block layout [hudi] via GitHub
  • Re: [PR] docs(hudi-io): document HFile offset and size widths and the non-root index block layout [hudi] via GitHub
• (hudi) branch master updated: fix(flink): retain files with missing column statistics (#20295) danny0405
• (hudi) branch master updated: fix(hfile): use long cursor offsets in native HFile reader for files larger than 2GB (#20309) pwason
• [PR] fix(flink): make the bucket pruning function serializable for source V2 [hudi] via GitHub
  • Re: [PR] fix(flink): make the bucket pruning function serializable for source V2 [hudi] via GitHub
  • Re: [PR] fix(flink): make the bucket pruning function serializable for source V2 [hudi] via GitHub
• (hudi) branch master updated: fix(common): correct incremental fallback reads when a stale non-write instant precedes the first active commit (#20273) yihua
• [I] [BUG] flink: Source V2 query filtering a bucket index table by its keys fails with NotSerializableException [hudi] via GitHub
  • Re: [I] [BUG] flink: Source V2 query filtering a bucket index table by its keys fails with NotSerializableException [hudi] via GitHub
• (hudi) branch master updated: fix(spark): honor 'earliest' begin instant in DataFrame CDC reads (#20304) codope
• [PR] fix(kafka-connect): treat a completed commit as successful when a post-commit action fails [hudi] via GitHub
  • Re: [PR] fix(kafka-connect): treat a completed commit as successful when a post-commit action fails [hudi] via GitHub
  • Re: [PR] fix(kafka-connect): treat a completed commit as successful when a post-commit action fails [hudi] via GitHub
• [I] [BUG] kafka-connect: sink rewrites committed records when a post-commit action fails [hudi] via GitHub
  • Re: [I] [BUG] kafka-connect: sink rewrites committed records when a post-commit action fails [hudi] via GitHub
• [PR] fix(flink): align bucket pruning with field-prefixed record keys [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with field-prefixed record keys [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with field-prefixed record keys [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with field-prefixed record keys [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with field-prefixed record keys [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with field-prefixed record keys [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with field-prefixed record keys [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with field-prefixed record keys [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with field-prefixed record keys [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with field-prefixed record keys [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with field-prefixed record keys [hudi] via GitHub
• [I] [BUG] flink: bucket pruning misses rows on tables with one primary key and multiple partition fields [hudi] via GitHub
• (hudi) branch master updated: fix(flink): reclaim empty checkpoint caches in record index (#20241) danny0405
• (hudi) branch master updated: fix(flink): preserve event-time delete ordering during precombine (#20288) danny0405
• [PR] fix(kafka-connect): retry start commit when the topic partition lookup fails [hudi] via GitHub
  • Re: [PR] fix(kafka-connect): retry start commit when the topic partition lookup fails [hudi] via GitHub
  • Re: [PR] fix(kafka-connect): retry start commit when the topic partition lookup fails [hudi] via GitHub
• [I] [BUG] kafka-connect: coordinator stops starting commits after a failed topic partition lookup [hudi] via GitHub
  • Re: [I] [BUG] kafka-connect: coordinator stops starting commits after a failed topic partition lookup [hudi] via GitHub
• [PR] fix(hfile): use long cursor offsets in native HFile reader for files larger than 2GB [hudi] via GitHub
  • Re: [PR] fix(hfile): use long cursor offsets in native HFile reader for files larger than 2GB [hudi] via GitHub
  • Re: [PR] fix(hfile): use long cursor offsets in native HFile reader for files larger than 2GB [hudi] via GitHub
  • Re: [PR] fix(hfile): use long cursor offsets in native HFile reader for files larger than 2GB [hudi] via GitHub
  • Re: [PR] fix(hfile): use long cursor offsets in native HFile reader for files larger than 2GB [hudi] via GitHub
  • Re: [PR] fix(hfile): use long cursor offsets in native HFile reader for files larger than 2GB [hudi] via GitHub
  • Re: [PR] fix(hfile): use long cursor offsets in native HFile reader for files larger than 2GB [hudi] via GitHub
• [PR] fix(archival)!: stop archiving beyond savepoint, which leaves timeline holes [hudi] via GitHub
  • Re: [PR] fix(archival)!: stop archiving beyond savepoint, which leaves timeline holes [hudi] via GitHub
  • Re: [PR] fix(archival)!: stop archiving beyond savepoint, which leaves timeline holes [hudi] via GitHub
  • Re: [PR] fix(archival)!: stop archiving beyond savepoint, which leaves timeline holes [hudi] via GitHub
  • Re: [PR] fix(archival)!: stop archiving beyond savepoint, which leaves timeline holes [hudi] via GitHub
  • Re: [PR] fix(archival)!: stop archiving beyond savepoint, which leaves timeline holes [hudi] via GitHub
  • Re: [PR] fix(archival)!: stop archiving beyond savepoint, which leaves timeline holes [hudi] via GitHub
• [I] Native HFile reader fails on HFiles larger than 2GB: cursor offset overflows int [hudi] via GitHub
  • Re: [I] Native HFile reader fails on HFiles larger than 2GB: cursor offset overflows int [hudi] via GitHub
• [PR] fix(spark): render decimal, date and timestamp values in CDC images [hudi] via GitHub
  • Re: [PR] fix(spark): render decimal, date and timestamp values in CDC images [hudi] via GitHub
  • Re: [PR] fix(spark): render decimal, date and timestamp values in CDC images [hudi] via GitHub
  • Re: [PR] fix(spark): render decimal, date and timestamp values in CDC images [hudi] via GitHub
  • Re: [PR] fix(spark): render decimal, date and timestamp values in CDC images [hudi] via GitHub
  • Re: [PR] fix(spark): render decimal, date and timestamp values in CDC images [hudi] via GitHub
  • Re: [PR] fix(spark): render decimal, date and timestamp values in CDC images [hudi] via GitHub
• [I] Shredded variant COW upsert fails on DECIMAL leaf: Avro fixed/record name collision on typed_value [hudi] via GitHub
  • Re: [I] Shredded variant COW upsert fails on DECIMAL leaf: Avro fixed/record name collision on typed_value [hudi] via GitHub
  • Re: [I] Shredded variant COW upsert fails on DECIMAL leaf: Avro fixed/record name collision on typed_value [hudi] via GitHub
  • Re: [I] Shredded variant COW upsert fails on DECIMAL leaf: Avro fixed/record name collision on typed_value [hudi] via GitHub
• (hudi-rs) branch main updated: build(deps-dev): bump mypy from 2.3.1 to 2.4.0 in /python (#818) yihua
• (hudi-rs) branch dependabot/pip/python/mypy-2.4.0 deleted (was f775b4ab) yihua
• Re: [PR] feat(variant): auto-infer per-file variant shredding schemas on shredding inference [hudi] via GitHub
• Re: [PR] feat(variant): support reading shredded variant base files via the AVRO reader [hudi] via GitHub
• [I] [Improvement] Avoid cross-partition hot-bucket concentration in RemotePartitioner [hudi] via GitHub
  • Re: [I] [Improvement] Avoid cross-partition hot-bucket concentration in RemotePartitioner [hudi] via GitHub
  • Re: [I] [Improvement] Avoid cross-partition hot-bucket concentration in RemotePartitioner [hudi] via GitHub
  • Re: [I] [Improvement] Avoid cross-partition hot-bucket concentration in RemotePartitioner [hudi] via GitHub
• [PR] fix(spark): honor 'earliest' begin instant in DataFrame CDC reads [hudi] via GitHub
  • Re: [PR] fix(spark): honor 'earliest' begin instant in DataFrame CDC reads [hudi] via GitHub
  • Re: [PR] fix(spark): honor 'earliest' begin instant in DataFrame CDC reads [hudi] via GitHub
  • Re: [PR] fix(spark): honor 'earliest' begin instant in DataFrame CDC reads [hudi] via GitHub
• [PR] fix(kafka-connect): close AdminClient after fetching topic partitions [hudi] via GitHub
  • Re: [PR] fix(kafka-connect): close AdminClient after fetching topic partitions [hudi] via GitHub
  • Re: [PR] fix(kafka-connect): close AdminClient after fetching topic partitions [hudi] via GitHub
• (hudi) branch master updated: fix(spark): decide vectorized read per scan in HoodieFileGroupReaderBasedFileFormat (#20183) codope
• [PR] feat(agent): Add first executable mutable Flink SQL MOR sink path to Hudi Architect [hudi] via GitHub
  • Re: [PR] feat(agent): Add first executable mutable Flink SQL MOR sink path to Hudi Architect [hudi] via GitHub
  • Re: [PR] feat(agent): Add first executable mutable Flink SQL MOR sink path to Hudi Architect [hudi] via GitHub
  • Re: [PR] feat(agent): Add first executable mutable Flink SQL MOR sink path to Hudi Architect [hudi] via GitHub
  • Re: [PR] feat(agent): Add first executable mutable Flink SQL MOR sink path to Hudi Architect [hudi] via GitHub
  • Re: [PR] feat(agent): Add first executable mutable Flink SQL MOR sink path to Hudi Architect [hudi] via GitHub
• (hudi) branch master updated: fix(kafka-connect): terminate transaction coordinator event loop on stop (#20271) danny0405
• (hudi) branch master updated: refactor: Rename dataFile/df variables to baseFile/bf (#19944) vhs
• Re: [I] Replace variables/comments named "data files" to "base file" [hudi] via GitHub
• [I] Docs for `hoodie.datasource.read.begin.instanttime` say inclusive, but the Spark incremental reader treats begin as exclusive [hudi] via GitHub
  • Re: [I] Docs for `hoodie.datasource.read.begin.instanttime` say inclusive, but the Spark incremental reader treats begin as exclusive [hudi] via GitHub
• [I] Spark DataFrame CDC read returns no rows when `hoodie.datasource.read.begin.instanttime` is `earliest` [hudi] via GitHub
  • Re: [I] Spark DataFrame CDC read returns no rows when `hoodie.datasource.read.begin.instanttime` is `earliest` [hudi] via GitHub
• [I] Spark CDC reads serialize DECIMAL columns incorrectly in `before`/`after` images (`{"zero":false}` on MOR, raw bytes on COW) [hudi] via GitHub
  • Re: [I] Spark CDC reads serialize DECIMAL columns incorrectly in `before`/`after` images (`{"zero":false}` on MOR, raw bytes on COW) [hudi] via GitHub
• [PR] fix(flink): treat missing column stats as unknown after index expansion [hudi] via GitHub
  • Re: [PR] fix(flink): treat missing column stats as unknown after index expansion [hudi] via GitHub
  • Re: [PR] fix(flink): treat missing column stats as unknown after index expansion [hudi] via GitHub
• (hudi) branch master updated: perf(core): avoid copying table properties for each native log file (#20297) danny0405
• (hudi) branch master updated: fix(hive-sync): keep the sync client's metastore client out of Hive's thread cache (#20219) danny0405
• (hudi) branch bot/trino-pin updated (4ff5dbdbff6d -> 5c6bebe35c3c) github-bot
  • (hudi) 01/01: chore(trino): advance trino master pin to 9b2f9488bef3 github-bot
• (hudi) branch master updated: fix(common): propagate stored disruptor consumer failures (#20026) danny0405
• (hudi) branch master updated: fix(flink): prevent write rate limiter stalls and thread leaks (#20189) danny0405
• Re: [I] [Feature][Agent] Add a deterministic Flink-native design path to Hudi Architect [hudi] via GitHub
• (hudi) branch master updated: feat(agent): add first mutable Flink SQL COW sink path to Hudi Architect (#20281) danny0405
• [PR] perf(core): lazily copy native log properties once per reader [hudi] via GitHub
  • Re: [PR] perf(core): lazily copy native log properties once per reader [hudi] via GitHub
  • Re: [PR] perf(core): avoid copying table properties for each native log file [hudi] via GitHub
  • Re: [PR] perf(core): avoid copying table properties for each native log file [hudi] via GitHub
• [I] Spark data skipping drops matching rows after adding columns to the column stats index [hudi] via GitHub
• [PR] fix(flink): align bucket pruning with compound key placeholders [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with compound key placeholders [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with compound key placeholders [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with compound key placeholders [hudi] via GitHub
  • Re: [PR] fix(flink): align bucket pruning with compound key placeholders [hudi] via GitHub

• Earlier messages
• Later messages