I ran `mvn dependency:tree` and only see 1.7.1 dependencies for Flink: [INFO] com.inin.analytics:analytics-flink:jar:0.0.1-SNAPSHOT [INFO] +- org.apache.flink:flink-streaming-java_2.11:jar:1.7.1:provided [INFO] | +- org.apache.flink:flink-runtime_2.11:jar:1.7.1:provided [INFO] | | +- org.apache.flink:flink-queryable-state-client-java_2.11:jar:1.7.1:provided [INFO] | | +- org.apache.flink:flink-hadoop-fs:jar:1.7.1:provided [INFO] | | +- commons-io:commons-io:jar:2.4:compile [INFO] | | +- org.apache.flink:flink-shaded-netty:jar:4.1.24.Final-5.0:provided [INFO] | | +- org.apache.flink:flink-shaded-asm:jar:5.0.4-5.0:provided [INFO] | | +- org.apache.flink:flink-shaded-jackson:jar:2.7.9-5.0:provided [INFO] | | +- org.javassist:javassist:jar:3.19.0-GA:provided [INFO] | | +- org.scala-lang:scala-library:jar:2.11.12:compile [INFO] | | +- com.typesafe.akka:akka-actor_2.11:jar:2.4.20:provided [INFO] | | | +- com.typesafe:config:jar:1.3.0:provided [INFO] | | | \- org.scala-lang.modules:scala-java8-compat_2.11:jar:0.7.0:provided [INFO] | | +- com.typesafe.akka:akka-stream_2.11:jar:2.4.20:provided [INFO] | | | \- com.typesafe:ssl-config-core_2.11:jar:0.2.1:provided [INFO] | | | \- org.scala-lang.modules:scala-parser-combinators_2.11:jar:1.0.4:provided [INFO] | | +- com.typesafe.akka:akka-protobuf_2.11:jar:2.4.20:provided [INFO] | | +- com.typesafe.akka:akka-slf4j_2.11:jar:2.4.20:provided [INFO] | | +- org.clapper:grizzled-slf4j_2.11:jar:1.3.2:provided [INFO] | | +- com.github.scopt:scopt_2.11:jar:3.5.0:provided [INFO] | | +- org.xerial.snappy:snappy-java:jar:1.1.4:compile [INFO] | | \- com.twitter:chill_2.11:jar:0.7.6:provided [INFO] | | \- com.twitter:chill-java:jar:0.7.6:provided [INFO] | +- org.apache.flink:flink-shaded-guava:jar:18.0-5.0:provided [INFO] | +- org.apache.commons:commons-math3:jar:3.5:compile [INFO] | \- org.apache.flink:force-shading:jar:1.7.1:compile [INFO] +- org.apache.flink:flink-clients_2.11:jar:1.7.1:provided [INFO] | +- org.apache.flink:flink-core:jar:1.7.1:provided [INFO] | | +- org.apache.flink:flink-annotations:jar:1.7.1:provided [INFO] | | +- org.apache.flink:flink-metrics-core:jar:1.7.1:provided [INFO] | | +- com.esotericsoftware.kryo:kryo:jar:2.24.0:provided [INFO] | | | +- com.esotericsoftware.minlog:minlog:jar:1.2:provided [INFO] | | | \- org.objenesis:objenesis:jar:2.1:provided [INFO] | | +- commons-collections:commons-collections:jar:3.2.2:provided [INFO] | | \- org.apache.commons:commons-compress:jar:1.4.1:compile [INFO] | +- org.apache.flink:flink-optimizer_2.11:jar:1.7.1:provided [INFO] | +- org.apache.flink:flink-java:jar:1.7.1:provided [INFO] | \- commons-cli:commons-cli:jar:1.3.1:provided [INFO] +- org.apache.flink:flink-avro:jar:1.7.1:compile [INFO] | \- org.apache.avro:avro:jar:1.8.2:compile [INFO] | +- org.codehaus.jackson:jackson-core-asl:jar:1.9.13:compile [INFO] | +- org.codehaus.jackson:jackson-mapper-asl:jar:1.9.13:compile [INFO] | +- com.thoughtworks.paranamer:paranamer:jar:2.7:compile [INFO] | \- org.tukaani:xz:jar:1.5:compile [INFO] +- org.apache.flink:flink-statebackend-rocksdb_2.11:jar:1.7.1:provided [INFO] | \- org.rocksdb:rocksdbjni:jar:5.7.5:provided [INFO] +- org.apache.flink:flink-connector-kafka-0.11_2.11:jar:1.7.1:compile [INFO] | +- org.apache.flink:flink-connector-kafka-0.10_2.11:jar:1.7.1:compile [INFO] | | \- org.apache.flink:flink-connector-kafka-0.9_2.11:jar:1.7.1:compile [INFO] | | \- org.apache.flink:flink-connector-kafka-base_2.11:jar:1.7.1:compile [INFO] | \- org.apache.kafka:kafka-clients:jar:0.11.0.2:compile [INFO] | \- net.jpountz.lz4:lz4:jar:1.3.0:compile [INFO] +- org.apache.flink:flink-s3-fs-presto:jar:1.7.1:provided
I also tried this again with debug logging enabled but didn't see any more messages that would explain the failure. To me, the error message (org.apache.flink.formats.avro.typeutils.AvroSerializer; local class incompatible: stream classdesc serialVersionUID = 1, local class serialVersionUID = 2) looks like this is caused by only having the 1.7.1 AvroSerializer class (serialVersionUID = 2) in the classpath but the savepoint requires the old one (serialVersionUID = 1). -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/