[
https://issues.apache.org/jira/browse/FLINK-33223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773558#comment-17773558
]
Dawid Wysakowicz edited comment on FLINK-33223 at 10/10/23 6:44 AM:
--------------------------------------------------------------------
Fixed in
* master
** 53ece12c25579497338ed59a7aebe70f2b3d9ed6
* 1.18.1
** 9b837727b6d369af9029c73a02bf5c43f0ce6201
was (Author: dawidwys):
Fixed in master: 53ece12c25579497338ed59a7aebe70f2b3d9ed6
> 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
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.19.0, 1.18.1
>
>
> {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)
