Flink(1.5.0) SQL stream non-windowed inner join

[徐林彬]

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

 

 

[Renjie Liu]

Could you please paste your sql here?

On Thu, Jun 14, 2018 at 2:54 PM 徐林彬 <[hidden email]> wrote:

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

 

 

--