[jira] [Commented] (FLINK-40159) Support Hive metastore sync for Hudi pipeline sink

["Xiqian Yu (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-40159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18120498#comment-18120498 ] 

Xiqian Yu commented on FLINK-40159:
-----------------------------------

Merged into master via a52fe0dcedc9e9f32add35e0f4105d661170b106.

> Support Hive metastore sync for Hudi pipeline sink
> --------------------------------------------------
>
>                 Key: FLINK-40159
>                 URL: https://issues.apache.org/jira/browse/FLINK-40159
>             Project: Flink
>          Issue Type: Improvement
>          Components: Flink CDC
>            Reporter: Bread S
>            Priority: Major
>              Labels: pull-request-available
>
> The Hudi pipeline sink accepts Hudi table properties through table.properties.* and forwards hive_sync.* options to Hudi configurations.
> However, MultiTableStreamWriteOperatorCoordinator overrides the original Hudi StreamWriteOperatorCoordinator lifecycle and commit flow, so the built-in Hudi hive sync logic is not triggered. As a result, data can be written to Hudi storage, but table metadata is not synced to Hive Metastore.
> YAML：
> {code:java}
> table.properties.hive_sync.enabled: "true"
> table.properties.hive_sync.mode: HMS {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)