[FLINK-6614] Applying function on window auxiliary function fails

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.3.0, 1.4.0
• Fix Version/s: 1.3.0, 1.4.0
• Component/s: Table SQL / API
• Assignee: Fabian Hueske
• Reporter: Fabian Hueske
• Created: 17/May/17 12:35
• Updated: 18/May/17 20:11
• Resolved: 18/May/17 20:11

Description

SQL queries that apply a function or expression on a window auxiliary function (TUMBLE_START, TUMBLE_END, HOP_START, etc). cannot be translated and fail with a CodeGenException:

Exception in thread "main" org.apache.flink.table.codegen.CodeGenException: Unsupported call: TUMBLE_END

Example query:

SELECT 
  a, 
  toLong(TUMBLE_END(rowtime, INTERVAL '10' MINUTE)) AS t, 
  COUNT(b) AS cntB
FROM myTable
GROUP BY a, TUMBLE(rowtime, INTERVAL '10' MINUTE)

Issue Links

• links to: GitHub Pull Request #3930