Does it work within the Flink Scala Shell? ________________________________ From: André Schütz <an...@wegtam.com> Sent: Wednesday, February 14, 2018 4:02:30 AM To: us...@zeppelin.incubator.apache.org Subject: NullPointerException in paragraph when getting batched TableEnvironment
Hi, within the Flink Interpreter context, we try to get a Batch TableEnvironment with the following code. [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 an...@wegtam.com | P: +49 (0) 381-80 699 041 | M: +49 (0) 176-218 02 604 www.wegtam.com<http://www.wegtam.com> | www.tensei-data.com<http://www.tensei-data.com> | www.wegtam.net<http://www.wegtam.net>
