Skip to content

[lake] Propagate Hadoop configuration to Hudi writer - #4584

Open
Gezi-lzq wants to merge 1 commit into
apache:mainfrom
Gezi-lzq:fix/hudi-write-client-hadoop-conf
Open

Gezi-lzq wants to merge 1 commit into
apache:mainfrom
Gezi-lzq:fix/hudi-write-client-hadoop-conf

Conversation

@Gezi-lzq

@Gezi-lzq Gezi-lzq commented Oct 10, 2026 •

Copy link
Copy Markdown
Contributor

Purpose

Closes #4585.

The Hudi write client currently uses HoodieFlinkEngineContext.DEFAULT, which does not inherit the Hadoop configuration assembled from the Hudi catalog settings. Consequently, S3A properties such as the endpoint and credentials are missing when Hudi accesses remote storage.

  • No generative AI tools used
  • Yes, OpenAI Codex was used to assist implementation, testing, and review

Brief change log

  • Construct the Hudi write client's Flink engine context from the configured flinkConfig
  • Preserve Hadoop filesystem properties, including S3A endpoint and credentials
  • Add regression coverage for both COW/log and MOR/primary-key tables

Tests

  • mise exec java@temurin-11 -- ./mvnw -pl fluss-lake/fluss-lake-hudi -am '-Dtest=org.apache.fluss.lake.hudi.**.*Test,org.apache.fluss.lake.hudi.**.*ITCase' -Dsurefire.failIfNoSpecifiedTests=false test
    • 113 tests passed, 0 failures, 0 errors, 0 skipped
  • DevKit with Flink 1.20.3, Hudi 1.1.0, and RustFS S3A storage
    • Verified Hudi writes, appends, primary-key updates, native Hudi reads, and Fluss Union Reads
    • Followed the documented Hudi workflows for primary-key, log, partitioned, option passthrough, and automatic compaction scenarios

API and Format

No public API or storage format changes.

Documentation

No documentation changes. The existing $lake limitation for Hudi is unrelated and outside this PR's scope.

@luoyuxia

Copy link
Copy Markdown
Contributor

cc @fhan688

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Bug] Hudi writer does not inherit Hadoop configuration

2 participants