Skip to content

Commit d884f4b

Browse files
committed
modify as alias exception prompt
1 parent 396b5b2 commit d884f4b

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -162,6 +162,11 @@ 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+
if (!selectList.get(index).getClass().equals(SqlIdentifier.class)) {
166+
throw new RuntimeException(String.format("Illegal statement! Please check the statement: %s",
167+
selectList.get(index).toString()));
168+
}
169+
165170
if (selectList.get(index).getKind().equals(SqlKind.AS)
166171
|| ((SqlIdentifier) selectList.get(index)).names.size() == 1) {
167172
sqlNodes.add(selectList.get(index));

0 commit comments

Comments
 (0)