Skip to content

Commit 153cdc9

Browse files
committed
Merge branch 'hotfix_1.10_4.0.x_33004' of http://gitlab.prod.dtstack.cn/dt-insight-engine/flinkStreamSQL into hotfix_1.10_4.0.x_33004
# Conflicts: # core/src/main/java/com/dtstack/flink/sql/parser/InsertSqlParser.java
2 parents a0d5fa7 + e520224 commit 153cdc9

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)