Hey,
I'm trying out 1.2 because I need the new Kafka 0.10 connector.
I compiled my job using the SNAPSHOT releases of flink 1.2 and the job
works fine in local mode.
The problem is that deploying the job to our EMR/YARN cluster fails with
a
-----
java.lang.VerifyError: Cannot inherit from final class
at java.lang.ClassLoader.defineClass1(Native Method)
-----
The full log is available here:
https://gist.github.com/theomega/18a40c36b5b12e62dad629c5cc4bc017
The job is from my local machine to our EMR cluster. My local machine
runs a Flink 1.2 SNAPSHOT.
Is this some kind of version conflict?
The dependencies for the job are (sbt project):
----
resolvers += "Relayr Repo" at
"https://s3-eu-west-1.amazonaws.com/relayr-maven";
resolvers += "Apache Snapshots" at
"https://repository.apache.org/content/groups/snapshots/";
val flinkDependencies = Seq(
"org.apache.flink" %% "flink-scala" % flinkVersion % "provided"
exclude("log4j", "log4j") exclude("org.slf4j", "slf4j-log4j12"),
"org.apache.flink" %% "flink-streaming-scala" % flinkVersion %
"provided" exclude("log4j", "log4j") exclude("org.slf4j",
"slf4j-log4j12"),
"org.apache.flink" %% "flink-connector-kafka-0.10" % flinkVersion
exclude("log4j", "log4j") exclude("org.slf4j", "slf4j-log4j12"),
"org.apache.flink" %% "flink-connector-cassandra" % flinkVersion
exclude("log4j", "log4j") exclude("org.slf4j", "slf4j-log4j12"),
"org.json" % "json" % "20160212",
"org.clapper" %% "grizzled-slf4j" % "1.3.0",
"ch.qos.logback" % "logback-classic" % "1.1.7" % "provided",
"com.datadoghq" % "java-dogstatsd-client" % "2.3",
"io.dropwizard.metrics" % "metrics-core" % "3.1.2",
"org.scalatest" %% "scalatest" % "2.2.6" % "test"
)
----
How can I debug this further?
Thanks,
Dominik
