[FLINK-11191] Exception in code generation when ambiguous columns in MATCH_RECOGNIZE

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.7.0, 1.8.0
• Fix Version/s: 1.7.2, 1.8.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 18/Dec/18 14:36
• Updated: 08/Jan/19 12:04
• Resolved: 08/Jan/19 12:04

Description

Query:

SELECT *
FROM Ticker
MATCH_RECOGNIZE (
  PARTITION BY symbol, price
  ORDER BY proctime
  MEASURES
    A.symbol AS symbol,
    A.price AS price
  PATTERN (A)
  DEFINE
    A AS symbol = 'a'
) AS T

throws a cryptic exception from the code generation stack that the output arity is wrong. We should add early validation and throw a meaningful exception.

I've also created a calcite ticket to fix it on calcite's side: CALCITE-2747

Issue Links

• is related to: CALCITE-2747 No exception when ambiguous column reference defined in PARTITION BY and MEASURES clause
• links to: GitHub Pull Request #7328