[jira] [Updated] (FLINK-33223) MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan

2023-10-10 Thread Dawid Wysakowicz (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-33223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Dawid Wysakowicz updated FLINK-33223:
-
Fix Version/s: 1.18.1

> 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)

[jira] [Updated] (FLINK-33223) MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan

2023-10-09 Thread ASF GitHub Bot (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-33223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ASF GitHub Bot updated FLINK-33223:
---
Labels: pull-request-available  (was: )

> 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)