diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/source/HiveScanNode.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/source/HiveScanNode.java index d4d471a461..0dbaa8b462 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/source/HiveScanNode.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/source/HiveScanNode.java @@ -362,7 +362,11 @@ public class HiveScanNode extends FileQueryScanNode { TFileTextScanRangeParams textParams = new TFileTextScanRangeParams(); java.util.Map delimiter = hmsTable.getRemoteTable().getSd().getSerdeInfo().getParameters(); if (delimiter.containsKey(PROP_FIELD_DELIMITER)) { - textParams.setColumnSeparator(delimiter.get(PROP_FIELD_DELIMITER)); + if (delimiter.get(PROP_FIELD_DELIMITER).length() == 0) { + textParams.setColumnSeparator(DEFAULT_FIELD_DELIMITER); + } else { + textParams.setColumnSeparator(delimiter.get(PROP_FIELD_DELIMITER)); + } } else if (delimiter.containsKey(PROP_SEPARATOR_CHAR)) { textParams.setColumnSeparator(delimiter.get(PROP_SEPARATOR_CHAR)); } else {