[FLINK-10638] Invalid table scan resolution for temporal join queries

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.7.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Piotr Nowojski
• Reporter: Timo Walther
• Created: 22/Oct/18 08:04
• Updated: 05/Nov/18 12:31
• Resolved: 05/Nov/18 12:31

Description

Registered tables that contain a temporal join are not properly resolved when performing a table scan.

A planning error occurs when registering a table with a temporal join and reading from it again.

LogicalProject(amount=[*($0, $4)])
  LogicalFilter(condition=[=($3, $1)])
    LogicalCorrelate(correlation=[$cor0], joinType=[inner], requiredColumns=[{2}])
      LogicalTableScan(table=[[_DataStreamTable_0]])
      LogicalTableFunctionScan(invocation=[Rates(CAST($cor0.rowtime):TIMESTAMP(3) NOT NULL)], rowType=[RecordType(VARCHAR(65536) currency, BIGINT rate, TIME ATTRIBUTE(ROWTIME) rowtime)], elementType=[class [Ljava.lang.Object;])

Issue Links

• links to: GitHub Pull Request #6893
• links to: GitHub Pull Request #6981