From 1e7e5f7c84c590e919ef9f4e32466d606b44fff2 Mon Sep 17 00:00:00 2001 From: jtchen-study <74713597+jtchen-study@users.noreply.github.com> Date: Tue, 17 Oct 2023 11:11:43 +0800 Subject: [PATCH] Update DFSUtil.java --- .../com/alibaba/datax/plugin/reader/hdfsreader/DFSUtil.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/hdfsreader/src/main/java/com/alibaba/datax/plugin/reader/hdfsreader/DFSUtil.java b/hdfsreader/src/main/java/com/alibaba/datax/plugin/reader/hdfsreader/DFSUtil.java index 0b297d55..720f8bf6 100644 --- a/hdfsreader/src/main/java/com/alibaba/datax/plugin/reader/hdfsreader/DFSUtil.java +++ b/hdfsreader/src/main/java/com/alibaba/datax/plugin/reader/hdfsreader/DFSUtil.java @@ -621,8 +621,9 @@ public class DFSUtil { } else if (StringUtils.equalsIgnoreCase(specifiedFileType, Constant.SEQ)) { return isSequenceFile(filepath, in); + } else if (StringUtils.equalsIgnoreCase(specifiedFileType, Constant.PARQUET)) { + return true; } - } catch (Exception e) { String message = String.format("检查文件[%s]类型失败,目前支持ORC,SEQUENCE,RCFile,TEXT,CSV五种格式的文件," + "请检查您文件类型和文件是否正确。", filepath);