Skip to content

Commit 7bf63ce

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

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -979,7 +979,7 @@ private SqlIdentifier checkAndReplaceJoinCondition(SqlNode node, Map<String, Str
979979
public Map<String, String> buildTmpTableFieldRefOriField(Set<String> fieldSet, String newTableAliasName){
980980
Map<String, String> refInfo = Maps.newConcurrentMap();
981981
for(String field : fieldSet){
982-
String[] fields = StringUtils.splitByWholeSeparator(field, "as");
982+
String[] fields = StringUtils.splitByWholeSeparator(field, " as ");
983983
if (fields != null) {
984984
fields = Stream
985985
.of(fields)

0 commit comments

Comments
 (0)