[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148327#comment-17148327 ]
franklin DREW commented on FLINK-18446: --------------------------------------- Thank you very much for your help. Thank you. I found relevant information on the official website. > 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 > Priority: Major > Attachments: image-2020-06-29-17-14-00-144.png, > image-2020-06-29-17-53-55-931.png, image-2020-06-30-12-51-24-055.png, > screenshot-1.png > > > 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)