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();