Dawid Wysakowicz created FLINK-33223:
----------------------------------------
Summary: MATCH_RECOGNIZE AFTER MATCH clause can not be
deserialised from a compiled plan
Key: FLINK-33223
URL: https://issues.apache.org/jira/browse/FLINK-33223
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Reporter: Dawid Wysakowicz
Assignee: Dawid Wysakowicz
Fix For: 1.19.0
{code}
String sql =
"insert into MySink"
+ " SELECT * FROM\n"
+ " MyTable\n"
+ " MATCH_RECOGNIZE(\n"
+ " PARTITION BY vehicle_id\n"
+ " ORDER BY `rowtime`\n"
+ " MEASURES \n"
+ " FIRST(A.`rowtime`) as startTime,\n"
+ " LAST(A.`rowtime`) as endTime,\n"
+ " FIRST(A.engine_temperature) as
Initial_Temp,\n"
+ " LAST(A.engine_temperature) as Final_Temp\n"
+ " ONE ROW PER MATCH\n"
+ " AFTER MATCH SKIP TO FIRST B\n"
+ " PATTERN (A+ B)\n"
+ " DEFINE\n"
+ " A as LAST(A.engine_temperature,1) is NULL OR
A.engine_temperature > LAST(A.engine_temperature,1),\n"
+ " B as B.engine_temperature <
LAST(A.engine_temperature)\n"
+ " )MR;";
util.verifyJsonPlan(String.format(sql, afterClause));
{code}
fails with:
{code}
Could not resolve internal system function '$SKIP TO LAST$1'. This is a bug,
please file an issue. (through reference chain:
org.apache.flink.table.planner.plan.nodes.exec.serde.JsonPlanGraph["nodes"]->java.util.ArrayList[3]->org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecMatch["matchSpec"]->org.apache.flink.table.planner.plan.nodes.exec.spec.MatchSpec["after"])
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
