Skip to content

Commit 8ef4eba

Browse files
author
yanxi0227
committed
support else in select
1 parent 45c6d11 commit 8ef4eba

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/SideSqlExec.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -435,7 +435,7 @@ private SqlNode replaceSelectFieldName(SqlNode selectNode, HashBasedTable<String
435435
}
436436
}
437437

438-
replaceSelectFieldName(elseNode, mappingTable, tableAlias);
438+
((SqlCase) selectNode).setOperand(3, replaceSelectFieldName(elseNode, mappingTable, tableAlias));
439439
return selectNode;
440440
}else if(selectNode.getKind() == OTHER){
441441
//不处理

0 commit comments

Comments
 (0)