Dear All??
I'm using the HMS template for Flink hive sync??The template is as follows The application deployment mode is Flink on yarn??However, the flink sync hive failed with the following error message: org.apache.hudi.exception.HoodieException: Got runtime exception when hive syncing unknown at org.apache.hudi.hive.HiveSyncTool.syncHoodieTable(HiveSyncTool.java:120) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] at org.apache.hudi.sink.StreamWriteOperatorCoordinator.syncHive(StreamWriteOperatorCoordinator.java:302) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] at org.apache.hudi.sink.utils.NonThrownExecutor.lambda$execute$0(NonThrownExecutor.java:93) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_261] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_261] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_261] Caused by: org.apache.hudi.hive.HoodieHiveSyncException: Failed to sync partitions for table unknown at org.apache.hudi.hive.HiveSyncTool.syncPartitions(HiveSyncTool.java:348) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] at org.apache.hudi.hive.HiveSyncTool.syncHoodieTable(HiveSyncTool.java:195) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] at org.apache.hudi.hive.HiveSyncTool.doSync(HiveSyncTool.java:131) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] at org.apache.hudi.hive.HiveSyncTool.syncHoodieTable(HiveSyncTool.java:117) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] ... 5 more Caused by: java.lang.IllegalArgumentException: Partition path tenant_id=******************** is not in the form yyyy/mm/dd at org.apache.hudi.hive.SlashEncodedDayPartitionValueExtractor.extractPartitionValuesInPath(SlashEncodedDayPartitionValueExtractor.java:55) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] at org.apache.hudi.hive.HoodieHiveClient.getPartitionEvents(HoodieHiveClient.java:163) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] at org.apache.hudi.hive.HiveSyncTool.syncPartitions(HiveSyncTool.java:339) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] at org.apache.hudi.hive.HiveSyncTool.syncHoodieTable(HiveSyncTool.java:195) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] at org.apache.hudi.hive.HiveSyncTool.doSync(HiveSyncTool.java:131) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] at org.apache.hudi.hive.HiveSyncTool.syncHoodieTable(HiveSyncTool.java:117) ~[hudi-flink-bundle_2.11-0.10.0.jar:0.10.0] ... 5 more The error prompt indicates that the partition field of the flink sync hive table must be of date type. Is that right? Ask for help best regards Luke Yan
