From 14e044c14745918c7681554262be76f5427c82c5 Mon Sep 17 00:00:00 2001 From: sivabalan Date: Sun, 19 Nov 2023 19:11:18 -0800 Subject: [PATCH] fixing compilation failure --- .../src/main/java/org/apache/hudi/util/CompactionUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/CompactionUtil.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/CompactionUtil.java index 7780204ae3d2..13b93d4c11fa 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/CompactionUtil.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/CompactionUtil.java @@ -113,7 +113,7 @@ public static void setPreCombineField(Configuration conf, HoodieTableMetaClient * @param conf The configuration * @param metaClient The meta client */ - public static void inferChangelogMode(Configuration conf, HoodieTableMetaClient metaClient) { + public static void inferChangelogMode(Configuration conf, HoodieTableMetaClient metaClient) throws Exception { TableSchemaResolver tableSchemaResolver = new TableSchemaResolver(metaClient); Schema tableAvroSchema = tableSchemaResolver.getTableAvroSchemaFromDataFile(); if (tableAvroSchema.getField(HoodieRecord.OPERATION_METADATA_FIELD) != null) {