Bread S created FLINK-40159:
-------------------------------
Summary: 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
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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)