From 47b2618d9b2b77de1c3744aece16cc8f6ef6ba9c Mon Sep 17 00:00:00 2001 From: superPiKaChu <1623857502@qq.com> Date: Fri, 23 Sep 2022 10:56:06 +0800 Subject: [PATCH] [hotfix-#565][chunjun-hdfs-connector] hadoop3.x version support orc (#1279) --- chunjun-connectors/chunjun-connector-hdfs/pom.xml | 2 +- .../chunjun/connector/hdfs/InputSplit/HdfsOrcInputSplit.java | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/chunjun-connectors/chunjun-connector-hdfs/pom.xml b/chunjun-connectors/chunjun-connector-hdfs/pom.xml index a521e22b2d..afb60b309c 100644 --- a/chunjun-connectors/chunjun-connector-hdfs/pom.xml +++ b/chunjun-connectors/chunjun-connector-hdfs/pom.xml @@ -13,7 +13,7 @@ ChunJun : Connectors : HDFS - 1.1.1 + 3.1.1 diff --git a/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/InputSplit/HdfsOrcInputSplit.java b/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/InputSplit/HdfsOrcInputSplit.java index 1e179fd1f0..f32219dea3 100644 --- a/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/InputSplit/HdfsOrcInputSplit.java +++ b/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/InputSplit/HdfsOrcInputSplit.java @@ -51,7 +51,9 @@ public HdfsOrcInputSplit(OrcSplit orcSplit, int splitNumber) throws IOException public OrcSplit getOrcSplit() throws IOException { ByteArrayInputStream bais = new ByteArrayInputStream(orcSplitData); DataInputStream dis = new DataInputStream(bais); - OrcSplit orcSplit = new OrcSplit(null, 0, 0, null, null, false, false, new ArrayList<>()); + OrcSplit orcSplit = + new OrcSplit( + null, null, 0, 0, null, null, false, false, new ArrayList<>(), 0, 0, null); orcSplit.readFields(dis); bais.close(); dis.close();