Hi all I'm trying to prove flink sql stream non-windowed inner join with flink 1.5.0, but it failed. Then i tried flink test case(flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/JoinItCase.testNonWindowInnerJoin) with java instead of scala, but it failed too. The problem is that program throws TableException which says cannot generate a valid execution plan for the given query, this exception indicates that the query uses an unsupported SQL feature. Is that a bug?How to solve this problem?
Thanks Emerson
