Flink 1.9 blink planner

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink 1.9 blink planner

kaka chen
Hi All:

We found TableEnvironment in Flink 1.9 blink planner didn't support
functions such as sqlUpdate() and  registerTableSink(), when I used Scala
api, it will throw error.

*Error:(61, 20) value sqlUpdate is not a member of
org.apache.flink.table.api.scala.StreamTableEnvironment.*

Is it normal? Could someone help, thanks.

Thanks,
Kaka Chen
Reply | Threaded
Open this post in threaded view
|

Re: Flink 1.9 blink planner

Jark Wu-2
Hi Kaka,

Thanks for trying to use blink planner.

We are working on bridging blink planner to the public API (i.e.
TableEnvironment) and this is on a good way.
Until then, we will remove blink's own TableEnvironment and use API's
TableEnvironment and your problem will be fixed.
Ideally, we can finish this at the end of this week.

Best,
Jark

On Thu, 4 Jul 2019 at 19:20, kaka chen <[hidden email]> wrote:

> Hi All:
>
> We found TableEnvironment in Flink 1.9 blink planner didn't support
> functions such as sqlUpdate() and  registerTableSink(), when I used Scala
> api, it will throw error.
>
> *Error:(61, 20) value sqlUpdate is not a member of
> org.apache.flink.table.api.scala.StreamTableEnvironment.*
>
> Is it normal? Could someone help, thanks.
>
> Thanks,
> Kaka Chen
>
Reply | Threaded
Open this post in threaded view
|

Re: Flink 1.9 blink planner

kaka chen
Hi Jark,

Got it. Thanks.

Thanks,
Kaka

Jark Wu <[hidden email]> 于2019年7月4日周四 下午8:30写道:

> Hi Kaka,
>
> Thanks for trying to use blink planner.
>
> We are working on bridging blink planner to the public API (i.e.
> TableEnvironment) and this is on a good way.
> Until then, we will remove blink's own TableEnvironment and use API's
> TableEnvironment and your problem will be fixed.
> Ideally, we can finish this at the end of this week.
>
> Best,
> Jark
>
> On Thu, 4 Jul 2019 at 19:20, kaka chen <[hidden email]> wrote:
>
> > Hi All:
> >
> > We found TableEnvironment in Flink 1.9 blink planner didn't support
> > functions such as sqlUpdate() and  registerTableSink(), when I used Scala
> > api, it will throw error.
> >
> > *Error:(61, 20) value sqlUpdate is not a member of
> > org.apache.flink.table.api.scala.StreamTableEnvironment.*
> >
> > Is it normal? Could someone help, thanks.
> >
> > Thanks,
> > Kaka Chen
> >
>