-
Notifications
You must be signed in to change notification settings - Fork 40
Description
I am trying to execute flink in spylon, for that I execute this code in the cell.
%%init_spark
launcher.packages = ["org.apache.flink:flink-scala_2.11:1.9.1",
"org.apache.flink:flink-streaming-scala_2.11:1.9.1",
"org.apache.flink:flink-connector-kafka_2.11:1.9.1",
"org.apache.flink:flink-avro:1.9.1",
"org.apache.flink:flink-jdbc_2.11:1.9.1",
"org.apache.flink:flink-metrics-prometheus_2.11:1.9.1"]
launcher.jars = ["file:///C:/Users/david/.ivy2/jars/org.apache.flink_flink-scala_2.11-1.9.1.jar"]
launcher.master = "local[4]"
launcher.conf.spark.executor.cores = 8
launcher.conf.spark.app.name = "MyApp"
then I start sparkcontext, and try to import flink
import org.apache.flink
But I get this error:
In the spark UI it looks like they are installed
Also the packages look like they are downloaded, with launcher.packages
Would anbody know how to make this work?
Thank you very much!!!


