Hi,
by looking at the source code it seems that your "batchEnvironment" is
null. Did you verify this?
Regards,
Timo
Am 2/14/18 um 1:01 PM schrieb André Schütz:
Hi,
within the Flink Interpreter context, we try to get a Batch
TableEnvironment with the following code. The code was executed within
a Apache Zeppelin paragraph.
[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.
[error]
Caused by: java.lang.ExceptionInInitializerError:
java.lang.NullPointerException
Caused by: java.lang.NullPointerException
at org.apache.flink.table.api.scala.BatchTableEnvironment.<init>
(BatchTableEnvironment.scala:47) at
org.apache.flink.table.api.TableEnvironment$.getTableEnvironment
(TableEnvironment.scala:1049)
[/error]
Any ideas why there is the NullPointerException?
I am grateful for any ideas.
Kind regards,
Andre
