Hi Jeff,
My apologies, I realise this was caused by an uber jar I had loaded as a spark
dependency which contained a conflicting library. Removing the dependency fixed
the issue.
I've shaded & rebuilt the jar and no longer seeing the issue.
Sorry for the confusion!
-Original Message-
Hi,
I tried to establish a connection from Zeppelin to the latest Flink
version (1.3.1)
Using the latest flink version I got
text: org.apache.flink.api.scala.DataSet[String] =
org.apache.flink.api.scala.DataSet@69b8836f
counts: org.apache.flink.api.scala.AggregateDataSet[(String, Int)] =
or
