Skip to content

Commit bec95c3

Browse files
author
gituser
committed
Merge branch 'hotfix_1.10_4.0.x_33004' into 1.10_release_4.0.x
2 parents 4bdb8ab + 3852e6d commit bec95c3

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,9 +169,15 @@ 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+
<<<<<<< HEAD
172173
&& (((SqlIdentifier) sqlNode).names.size() == 1
173174
// sqlNode like 't.*'
174175
|| StringUtils.isBlank(((SqlIdentifier) sqlNode).names.get(1)));
176+
=======
177+
&& (((SqlIdentifier) sqlNode).isSimple()
178+
// sqlNode like 't.*'
179+
|| ((SqlIdentifier) sqlNode).isStar());
180+
>>>>>>> e52022440e11ac5d851e44be4c0c529050223903
175181

176182
if (isAsNode || isIdentifierOrStar) {
177183
sqlNodes.add(sqlNode);

0 commit comments

Comments
 (0)