SendDreams opened a new issue, #20485:
URL: https://github.com/apache/hudi/issues/20485
### Bug Description
1.flink 2.0 ,hive 4.0.1, hudi-flink2.0-bundle-1.2.0.jar
2.create table:
CREATE TABLE testlu_newtest_0010 (
`id` DECIMAL(20),
`name` STRING,
`sex` STRING,
`age` INT,
`ts` TIMESTAMP COMMENT 'hudi合并校验字段',
PRIMARY KEY(id) NOT ENFORCED
) WITH (
'connector' = 'hudi',
'path' = 'hdfs://GWNS:8020/user/hudi/testlu_newtest_0010',
'table.type' = 'MERGE_ON_READ',
'precombine.field' = 'ts',
'read.start-commit' = 'earliest',
'read.streaming.enabled' = 'true',
'changelog.enabled' = 'true',
'clean.retain_hours' = '1',
'clean.policy' = 'KEEP_LATEST_BY_HOURS',
'compaction.delta_seconds' = '300',
'compaction.trigger.strategy' = 'num_or_time',
'hive_sync.enable' = 'true',
'hive_sync.mode' = 'jdbc',
'hive_sync.jdbc_url' = 'jdbc:hive2://10.16.23.84:10000/ods',
-- 显式提供用户名，随便给一个密码
'hive_sync.username' = 'hive',
'hive_sync.password' = 'hive',
'hive_sync.conf.dir' = '/etc/hive/conf',
'hive_sync.db' = 'ods',
'hive_sync.table' = 'testlu_newtest_0010',
'hive_sync.support_timestamp' = 'true'
);
3.insert data to table:
INSERT INTO offline.ods.testlu_newtest_0010 VALUES (
CAST(1 AS DECIMAL(20, 0)),
'lu1',
'nan1',
18,
CAST('2026-09-09 12:12:12' AS TIMESTAMP(6))
);
4.flink jobmanager throw exception:
2026-10-30 16:24:47,260 ERROR
org.apache.hudi.sink.StreamWriteOperatorCoordinator [] - Executor
executes action [handle end input event for instant 20261030162445953] error
java.lang.NoSuchFieldError: METASTOREURIS
at
org.apache.hudi.hive.HiveSyncTool.syncHoodieTable(HiveSyncTool.java:177)
~[hudi-flink2.0-bundle-1.2.0.jar:1.2.0]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.doSyncHive(StreamWriteOperatorCoordinator.java:474)
~[hudi-flink2.0-bundle-1.2.0.jar:1.2.0]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.syncHive(StreamWriteOperatorCoordinator.java:464)
~[hudi-flink2.0-bundle-1.2.0.jar:1.2.0]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.handleEndInputEvent(StreamWriteOperatorCoordinator.java:582)
~[hudi-flink2.0-bundle-1.2.0.jar:1.2.0]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.lambda$handleEventFromOperator$4(StreamWriteOperatorCoordinator.java:354)
~[hudi-flink2.0-bundle-1.2.0.jar:1.2.0]
at
org.apache.hudi.sink.utils.NonThrownExecutor.lambda$wrapAction$0(NonThrownExecutor.java:131)
~[hudi-flink2.0-bundle-1.2.0.jar:1.2.0]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[?:?]
at java.lang.Thread.run(Thread.java:840) [?:?]
2026-10-30 16:24:47,261 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - stream_write:
ods.testlu_newtest_0010 -> compact_plan_generate (1/1)
(fac71b98b5cdd5957ef4da53361a0723_b77492e7171a7e7ebc6e14ef33e8f8c5_0_0)
switched from RUNNING to FINISHED.
2026-10-30 16:24:47,264 INFO org.apache.flink.runtime
### Environment
**Hudi version:**
**Query engine:** (Spark/Flink/Trino etc)
**Relevant configs:**
### Logs and Stack Trace
_No response_
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
