Skip to content

Commit 7935aa7

Browse files
committed
modify as alias exception prompt
modify as alias exception prompt modify as alias exception prompt
1 parent 56d8382 commit 7935aa7

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

core/src/main/java/com/dtstack/flink/sql/parser/InsertSqlParser.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -162,6 +162,7 @@ private static void rebuildSelectNode(SqlNodeList selectList, SqlSelect sqlSelec
162162
SqlNodeList sqlNodes = new SqlNodeList(selectList.getParserPosition());
163163

164164
for (int index = 0; index < selectList.size(); index++) {
165+
165166
if (selectList.get(index).getKind().equals(SqlKind.AS)
166167
|| (selectList.get(index).getClass().equals(SqlIdentifier.class)
167168
&& ((SqlIdentifier) selectList.get(index)).names.size() == 1)) {

0 commit comments

Comments
 (0)