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!!!
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!!!