From 33a609cfa30aeff9c7d227ead88ec66ea1149801 Mon Sep 17 00:00:00 2001
From: liumengkai <1623857502@qq.com>
Date: Thu, 22 Sep 2022 20:17:04 +0800
Subject: [PATCH] [hotfix-#987] [chunjun-connector-hdfs] fixed
 HdfsOrcOutputFormat can't get fullColumnType or fullColumnName from HdfsConf

---
 .../chunjun/connector/hdfs/sink/BaseHdfsOutputFormat.java       | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/BaseHdfsOutputFormat.java b/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/BaseHdfsOutputFormat.java
index 3fce4e961c..5b81c0c9aa 100644
--- a/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/BaseHdfsOutputFormat.java
+++ b/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/BaseHdfsOutputFormat.java
@@ -83,6 +83,7 @@ protected void initVariableFields() {
                     hdfsConf.getColumn().stream()
                             .map(FieldConf::getName)
                             .collect(Collectors.toList());
+            hdfsConf.setFullColumnName(fullColumnNameList);
         }
 
         if (CollectionUtils.isNotEmpty(hdfsConf.getFullColumnType())) {
@@ -92,6 +93,7 @@ protected void initVariableFields() {
                     hdfsConf.getColumn().stream()
                             .map(FieldConf::getType)
                             .collect(Collectors.toList());
+            hdfsConf.setFullColumnName(fullColumnNameList);
         }
         compressType = getCompressType();
         super.initVariableFields();