franklin DREW created FLINK-18446:
-------------------------------------
Summary: Flink SQL CEP can no recognize keywords MATCH_RECOGINZE
from Joins
Key: FLINK-18446
URL: https://issues.apache.org/jira/browse/FLINK-18446
Project: Flink
Issue Type: Test
Components: API / DataStream
Affects Versions: 1.8.1
Reporter: franklin DREW
sql text :
insert
into
test_result
select
`start_timestamp`,
`end_timestamp`,
`event`,
y.mobileno,
case
when trim(x.lastcomplete_step) is null then 'wcsjhyz'
else TRIM(x.lastcomplete_step)
end as lastcomplete_step,
z.step_name,
y.branchno,
y.custname,
case
when TRIM(y.brokerno) is null then '空'
else TRIM(y.brokerno)
end as brokerno,
ROWTIME
FROM
rt_wskh_t_accepted_schedule x,
rt_wskh_t_accepted_cert_info y,
dic_cust_break z
WHERE
x.user_id = y.id
and case
when trim(x.lastcomplete_step) is null then 'wcsjhyz'
else trim(x.lastcomplete_step)
end = z.step_code
AND (
TRIM(x.lastcomplete_step) is null
or x.lastcomplete_step <> 'visitsurvey'
) MATCH_RECOGINZE ( PARTITION
BY
y.mobileno
ORDER BY
ROWTIME MEASURES e2.`x.lastcomplete_step` as `event`,
e1.`ROWTIME` as `start_timestamp`,
LAST(e2.`ROWTIME`) as `end_timestamp` ONE ROW PER MATCH AFTER MATCH SKIP TO
NEXT ROW PATTERN (e1 e2+) WITHIN INTERVAL '20' MINUTE DEFINE e1 as
e1.x.lastcomplete_step = e2.x.lastcomplete_step );
error info:<error> org.apache.flink.table.api.SqlParserException: SQL parse
failed. Encountered "MATCH_RECOGINZE" at line 1, column 1078.
Was expecting one of:
<EOF>
"ORDER" ...
"LIMIT" ...
"OFFSET" ...
"FETCH" ...
"GROUP" ...
"HAVING" ...
"WINDOW" ...
"UNION" ...
"INTERSECT" ...
"EXCEPT" ...
"MINUS" ...
"NOT" ...
"IN" ...
"<" ...
"<=" ...
">" ...
">=" ...
"=" ...
"<>" ...
"!=" ...
"BETWEEN" ...
"LIKE" ...
"SIMILAR" ...
"+" ...
"-" ...
"*" ...
"/" ...
"%" ...
"||" ...
"AND" ...
"OR" ...
"IS" ...
"MEMBER" ...
"SUBMULTISET" ...
"CONTAINS" ...
"OVERLAPS" ...
"EQUALS" ...
"PRECEDES" ...
"SUCCEEDS" ...
"IMMEDIATELY" ...
"MULTISET" ...
"[" ...
"YEAR" ...
"MONTH" ...
"DAY" ...
"HOUR" ...
"MINUTE" ...
"SECOND" ...
at
org.apache.flink.table.calcite.FlinkPlannerImpl.parse(FlinkPlannerImpl.scala:94)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
