From d3c17e5569686880c562b97d7d878d5de485cba0 Mon Sep 17 00:00:00 2001
From: shenk-b <shenk-b@glodon.com>
Date: Wed, 22 Jun 2022 18:32:40 +0800
Subject: [PATCH] fix:https://github.com/DTStack/chunjun/issues/987

---
 .../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..562b7753ef 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.setFullColumnType(fullColumnTypeList);
         }
         compressType = getCompressType();
         super.initVariableFields();