Skip to content

Conversation

@xiaochen-zhou
Copy link
Contributor

@xiaochen-zhou xiaochen-zhou commented Oct 25, 2025

Purpose of this pull request

Add branch option for paimon sink


sink {
  Paimon {
    warehouse = "/tmp/seatunnel_mnt/paimon"
    database = "default"
    table = "st_test_p"
    branch = "test-branch"
  }
}

Does this PR introduce any user-facing change?

Yes

How was this patch tested?

Add new e2e tests: PaimonSinkBranchIT

Check list

[Improve][Connector-V2] Add branch field option for paimon sink

fix failures tests

[Improve][Connector-V2] Add branch option for paimon sink

[Improve][Connector-V2] Add branch option for paimon sink

fix e2e failures
@xiaochen-zhou xiaochen-zhou force-pushed the feature/writer-special-branch branch from 2d34841 to 11d2326 Compare October 26, 2025 08:11
@davidzollo
Copy link
Contributor

Should PaimonSaveModeHandler also handle it?
Considering that schema_save_mode = "RECREATE_SCHEMA"

    Table paimonTable = ((PaimonCatalog) catalog).getPaimonTable(tablePath);

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

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants