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 via email to