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)