Skip to content

Commit 030d8e1

Browse files
committed
Merge branch 'hotfix_1.10_4.0.x_33004' into hotfix_1.10_4.0.x_33004_merge
2 parents 4bdb8ab + 153cdc9 commit 030d8e1

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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)