You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2023/10/10 06:43:00 UTC
[jira] [Closed] (FLINK-33223) MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan
[ https://issues.apache.org/jira/browse/FLINK-33223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dawid Wysakowicz closed FLINK-33223.
------------------------------------
Resolution: Fixed
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
>
>
> {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)