This is an automated email from the ASF dual-hosted git repository. pwason pushed a commit to branch release-0.14.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 544e999c005446c3c98c53e78daa73b2abbfd5ea Author: Nicholas Jiang <[email protected]> AuthorDate: Fri Aug 18 10:03:12 2023 +0800 [MINOR] StreamerUtil#getTableConfig should check whether hoodie.properties exists (#9464) --- .../hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java index 4912c0abf03..842e732abd4 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java @@ -312,7 +312,7 @@ public class StreamerUtil { FileSystem fs = FSUtils.getFs(basePath, hadoopConf); Path metaPath = new Path(basePath, HoodieTableMetaClient.METAFOLDER_NAME); try { - if (fs.exists(metaPath)) { + if (fs.exists(new Path(metaPath, HoodieTableConfig.HOODIE_PROPERTIES_FILE))) { return Option.of(new HoodieTableConfig(fs, metaPath.toString(), null, null)); } } catch (IOException e) {
