Re: NullPointerException when asking for batched TableEnvironment

2018-02-14 Thread André Schütz
+0100 Timo Walther wrote: > 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, > > > > w

NullPointerException when asking for batched TableEnvironment

2018-02-14 Thread 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 bat

Accessing Cassandra for reading and writing

2017-11-17 Thread André Schütz
Hi, we want to read and write from and to Cassandra. We found the Flink-Cassandra connector and added the JAR to the lib folder of the running Flink cluster (local machine). Trying to access the Cassandra database by adding the import to a notebook within Apache Zeppelin, resulted in the followi