How to create TableEnvrionment using scala-shell

[kant kodali]

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!!

[kant kodali]

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 <[hidden email]> 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!!