Skip to content

Commit b24aa11

Browse files
修正替换时的错误
1 parent 5693662 commit b24aa11

File tree

1 file changed

+1
-1
lines changed
  • impala/impala-side/impala-side-core/src/main/java/com/dtstack/flink/sql/side/impala/table

1 file changed

+1
-1
lines changed

impala/impala-side/impala-side-core/src/main/java/com/dtstack/flink/sql/side/impala/table/ImpalaSideParser.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ public TableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, O
9696
String partitionfieldsStr = MathUtil.getString(props.get(ImpalaSideTableInfo.PARTITIONFIELDS_KEY.toLowerCase()));
9797
impalaSideTableInfo.setPartitionfields(StringUtils.split(partitionfieldsStr, ","));
9898
String partitionfieldTypesStr = MathUtil.getString(props.get(ImpalaSideTableInfo.PARTITIONFIELDTYPES_KEY.toLowerCase()));
99-
impalaSideTableInfo.setPartitionFieldTypes(StringUtils.split(partitionfieldsStr, ","));
99+
impalaSideTableInfo.setPartitionFieldTypes(StringUtils.split(partitionfieldTypesStr, ","));
100100
String partitionfieldValuesStr = MathUtil.getString(props.get(ImpalaSideTableInfo.PARTITIONVALUES_KEY.toLowerCase()));
101101
impalaSideTableInfo.setPartitionValues(setPartitionFieldValues(partitionfieldValuesStr));
102102
}

0 commit comments

Comments
 (0)