Skip to content

Commit 23bc4aa

Browse files
committed
Merge branch 'hotfix_1.10_4.0.x_33465' into '1.10_release_4.0.x'
[fix-33465][core]别名使用AS字符串切割问题修复 See merge request dt-insight-engine/flinkStreamSQL!199
2 parents 162a6f9 + c297a4d commit 23bc4aa

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

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

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -979,7 +979,12 @@ 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;
983+
if (StringUtils.contains(field, " AS ")) {
984+
fields = StringUtils.splitByWholeSeparator(field, " AS ");
985+
} else {
986+
fields = StringUtils.splitByWholeSeparator(field, " as ");
987+
}
983988
if (fields != null) {
984989
fields = Stream
985990
.of(fields)

0 commit comments

Comments
 (0)