Skip to content

Commit c3d0564

Browse files
author
gituser
committed
Merge branch '1.10_release_4.0.x' into 1.10_release_4.1.x
2 parents 4549ec6 + 030d8e1 commit c3d0564

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -169,9 +169,9 @@ private static void rebuildSelectNode(SqlNodeList selectList, SqlSelect sqlSelec
169169
// 判断sqlNode的结构是否属于'f1' 或者 't.*'
170170
boolean isIdentifierOrStar = sqlNode.getClass().equals(SqlIdentifier.class)
171171
// sqlNode like 'f1'
172-
&& (((SqlIdentifier) sqlNode).names.size() == 1
172+
&& (((SqlIdentifier) sqlNode).isSimple()
173173
// sqlNode like 't.*'
174-
|| StringUtils.isBlank(((SqlIdentifier) sqlNode).names.get(1)));
174+
|| ((SqlIdentifier) sqlNode).isStar());
175175

176176
if (isAsNode || isIdentifierOrStar) {
177177
sqlNodes.add(sqlNode);

0 commit comments

Comments
 (0)