Thanks Chiwan. It worked.
Now I have this simple streaming program in Spark Scala that gets streaming
data via Kafka. It is pretty simple. Please see attached.
I am trying to make it work with Flink + Kafka
Any hints will be appreciated.
Thanks
Dr Mich Talebzadeh
LinkedIn *
https://www.l
Hi Mich,
You can add external dependencies to Scala shell using `--addclasspath` option.
There is more detail description in documentation [1].
[1]:
https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/scala_shell.html#adding-external-dependencies
Regards,
Chiwan Park
> On Apr 17,
Hi,
IN Spark shell I can load Kafka jar file through spark-shell option --jar
spark-shell --master spark://50.140.197.217:7077 --jars
,/home/hduser/jars/spark-streaming-kafka-assembly_2.10-1.6.1.jar
This works fine.
In Flink I have added the jar file
/home/hduser/jars/flink-connector-kafka-0.10
