flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From André Schütz <an...@wegtam.com>
Subject NullPointerException when asking for batched TableEnvironment
Date Wed, 14 Feb 2018 12:01:21 GMT
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

-- 
Andre Schütz
COO / Founder - Wegtam GmbH
andre@wegtam.com | P: +49 (0) 381-80 699 041 | M: +49 (0) 176-218 02 604
www.wegtam.com | www.tensei-data.com | www.wegtam.net

Mime
View raw message