flink sql 导入数据的语句不能编写where过滤条件吗?如果没有加where条件就正常导入成功 #2080
Unanswered
kuailedelaojia
asked this question in
Q&A
Replies: 1 comment
-
这个原因已经找到了,感谢社区的大佬帮忙排查,原因是sql语句换行符的问题,换一个编译器复制出来就可以了 |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
创建完表后最后导入数据到es执行语句:
INSERT INTO goods_doc
SELECT
t1.id AS goodsId,
t1.
name
AS goodsName,0 AS productId,
t1.pic AS attachmentUrl,
'' AS barCode,
t1.price AS sellingPrice,
t1.sale AS totalSale,
1 AS goodsType,
1 AS drugType,
t1.publish_status AS publishStatus,
1 AS goodsMonthSales,
t1.UPDATE_TIME AS updateTime,
t1.DELETED AS deleted,
t5.id AS orgId,
t5.name AS orgName,
t5.LOGO_URL AS orgLogo,
t5.BUSINESS_STATUS AS businessStatus,
t5.LNG AS lon,
t5.LAT AS lat,
t5.EXPRESS_FEE AS orgExpressFee
FROM
pms_spu_good_service t1
LEFT JOIN un_pharmacy t5 ON t1.org_id = t5.id
WHERE
t1.DELETED="0"
and t1.IS_AVAILABLE=1
and t1.verify_status=2
执行后报错:
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.sql.parser.impl.ParseException: Encountered "!= WHERE" at line 30, column 1.
Was expecting one of:
"EXCEPT" ...
"FETCH" ...
"GROUP" ...
"HAVING" ...
"INTERSECT" ...
"LIMIT" ...
"OFFSET" ...
"ORDER" ...
"MINUS" ...
"UNION" ...
"WHERE" ...
"WINDOW" ...
";" ...
"NATURAL" ...
"JOIN" ...
"INNER" ...
"LEFT" ...
"RIGHT" ...
"FULL" ...
"CROSS" ...
"," ...
"OUTER" ...
"." ...
"NOT" ...
"IN" ...
"<" ...
"<=" ...
">" ...
">=" ...
"=" ...
"<>" ...
"!=" "SOME" ...
"!=" "ANY" ...
"!=" "ALL" ...
"BETWEEN" ...
"LIKE" ...
"SIMILAR" ...
"!=" "+" ...
"!=" "-" ...
"!=" "NOT" ...
"!=" "EXISTS" ...
"!=" "INTERVAL" ...
"!=" <UNSIGNED_INTEGER_LITERAL> ...
"!=" <DECIMAL_NUMERIC_LITERAL> ...
"!=" <APPROX_NUMERIC_LITERAL> ...
"!=" <BINARY_STRING_LITERAL> ...
"!=" <PREFIXED_STRING_LITERAL> ...
"!=" <QUOTED_STRING> ...
"!=" <UNICODE_STRING_LITERAL> ...
"!=" <BIG_QUERY_DOUBLE_QUOTED_STRING> ...
"!=" <BIG_QUERY_QUOTED_STRING> ...
ps:如果没有加where条件就正常导入成功
Beta Was this translation helpful? Give feedback.
All reactions