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