Hi Ankur,
I'm catching up with this week mailing list right now; I hope you already
solved the issue, but if you haven't this kind of problem happen when you
use a version of Scala for which your Flink dependencies have not been
compiled for. Make sure you append the correct Scala version to the
d
Hi,
I am getting following error while executing the fat jar of project: Any help?
Exception in thread "main" java.lang.NoClassDefFoundError:
org/apache/flink/streaming/util/serialization/DeserializationSchema
at org.mpi.debs.Main.main(Main.scala)
Caused by: java.lang.ClassNotFoundExc
Hey Ankur,
Add the following line to your imports, and have a look at the referenced
FAQ. [1]
import org.apache.flink.streaming.api.scala._
[1]
https://flink.apache.org/faq.html#in-scala-api-i-get-an-error-about-implicit-values-and-evidence-parameters
Best,
Marton
On Sun, Mar 6, 2016 at 8:17
