Does it work within the Flink Scala Shell?

From: André Schütz <>
Sent: Wednesday, February 14, 2018 4:02:30 AM
Subject: NullPointerException in paragraph when getting batched TableEnvironment


within the Flink Interpreter context, we try to get a Batch
TableEnvironment with the following code.

import org.apache.flink.table.api._
import org.apache.flink.table.api.scala._
import org.apache.flink.table.sources._

val batchEnvironment      = benv
val batchTableEnvironment = TableEnvironment.getTableEnvironment
(batchEnvironment) [/code]

When executing the paragraph, we get the following error.

Caused by: java.lang.ExceptionInInitializerError:
Caused by: java.lang.NullPointerException
  at org.apache.flink.table.api.scala.BatchTableEnvironment.<init>
(BatchTableEnvironment.scala:47) at

Any ideas why there is the NullPointerException?

I am grateful for any ideas.

Kind regards,

Andre Schütz
COO / Founder - Wegtam GmbH | P: +49 (0) 381-80 699 041 | M: +49 (0) 176-218 02 604<> |<> |<>

Reply via email to