Flink(1.5.0) SQL stream non-windowed inner join

[徐林彬 <xl...@163.com>]

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




 

Re: Flink(1.5.0) SQL stream non-windowed inner join

[Renjie Liu <li...@gmail.com>]

Could you please paste your sql here?

On Thu, Jun 14, 2018 at 2:54 PM 徐林彬 <xl...@163.com> 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
>
>
>
>
>
>
>
-- 
Liu, Renjie
Software Engineer, MVAD