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
Hello,
I am trying to use a custom source function (declaration given below) for
DataStream.
if I add the source to stream using add source:
val stream = env.addSource(new QueryOneSource(args))
I get following error: Any explanations and help ??
Error:(14, 31) could not find implicit value fo
