[jira] [Created] (FLINK-19792) Interval join with equal time attributes is not recognized

[Shang Yuanchun (Jira)]

Timo Walther created FLINK-19792:
------------------------------------

             Summary: Interval join with equal time attributes is not recognized
                 Key: FLINK-19792
                 URL: https://issues.apache.org/jira/browse/FLINK-19792
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Planner
            Reporter: Timo Walther


A user reported that interval joins with equal time attribute predicate is not recognized, instead a regular inner join is used:

For example:
{code}
table1 = table_env.from_path("table1")
table2 = table_env.from_path("table2")

print(table1.join(table2).where("ts = ts2 && id = id2").select("id, ts")
{code}

The documentation clearly states that this should be supported:
{code}
For example, the following predicates are valid interval join conditions:

ltime === rtime
ltime >= rtime && ltime < rtime + 10.minutes
{code}
Source: https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/tableApi.html#joins

See also the discussion here:
https://stackoverflow.com/q/64445207/806430



--
This message was sent by Atlassian Jira
(v8.3.4#803005)