Please ignore this. I fixed it by moving opt/flink-table_2.11-1.4.1.jar to
lib/flink-table_2.11-1.4.1.jar

On Sat, Feb 24, 2018 at 4:06 AM, kant kodali <kanth...@gmail.com> wrote:

> Hi All,
>
> I am new to Flink and I am wondering how to create a TableEnvironment in
> scala-shell?  I get an import error below. I am using Flink 1.4.1
>
> 63:error: object table is not a member of package org.apache.flink`
>
>
> I tried to do the following
>
> ./start-scala-shell.sh local
>
> import org.apache.flink.table.api.scala._
>
> import org.apache.flink.table.api.TableEnvironment
>
>
> val tableEnv = TableEnvironment.getTableEnvironment(senv)
>
>
> Thanks!!
>
>
>

Reply via email to