Skip to content

Commit cd6c171

Browse files
committed
[fix-33465][core]别名使用as字符串切割问题修复
1 parent ab69eb8 commit cd6c171

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

core/src/main/java/com/dtstack/flink/sql/side/JoinNodeDealer.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,7 @@
5353
import java.util.Queue;
5454
import java.util.Set;
5555
import java.util.Arrays;
56+
import java.util.stream.Stream;
5657

5758
import static org.apache.calcite.sql.SqlKind.*;
5859

@@ -979,6 +980,12 @@ public Map<String, String> buildTmpTableFieldRefOriField(Set<String> fieldSet, S
979980
Map<String, String> refInfo = Maps.newConcurrentMap();
980981
for(String field : fieldSet){
981982
String[] fields = StringUtils.splitByWholeSeparator(field, "as");
983+
if (fields != null) {
984+
fields = Stream
985+
.of(fields)
986+
.map(StringUtils::trimToNull)
987+
.toArray(String[]::new);
988+
}
982989
String oldKey = field;
983990
String[] oldFieldInfo = StringUtils.splitByWholeSeparator(fields[0], ".");
984991
String oldFieldName = oldFieldInfo.length == 2 ? oldFieldInfo[1] : oldFieldInfo[0];

0 commit comments

Comments
 (0)