Hi all, I am trying to use Cassandra (v3.5) from spark (v1.6.0 - CDH 5.7) via the datastax connector (1.6.0-M2) in scala (2.10.5). My initial test runs fine locally, but when I try to deploy it to a test machine I am getting the following exception:
16/05/09 23:04:25 WARN Lost task 0.0 in stage 1.0 (TID 8, hcompute005.internal.shopkick.com): java.lang.UnsupportedClassVersionError: org/apache/cassandra/utils/UUIDGen : Unsupported major.minor version 52.0 at java.lang.ClassLoader.defineClass1(Native Method) at java.lang.ClassLoader.defineClass(ClassLoader.java:800) at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) at java.net.URLClassLoader.defineClass(URLClassLoader.java:449) at java.net.URLClassLoader.access$100(URLClassLoader.java:71) at java.net.URLClassLoader$1.run(URLClassLoader.java:361) at java.net.URLClassLoader$1.run(URLClassLoader.java:355) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:354) at java.lang.ClassLoader.loadClass(ClassLoader.java:425) at java.lang.ClassLoader.loadClass(ClassLoader.java:358) at sandbox.ben.cassandra.UserActivityTransformLoader.extractUserActivity(UserActivityTransformLoader.scala:121) The line of code that is failing is just: UUIDGen.getTimeUUID(timestamp).toString The java version in this environment is: $ java -version java version "1.8.0_91" Java(TM) SE Runtime Environment (build 1.8.0_91-b14) Java HotSpot(TM) 64-Bit Server VM (build 25.91-b14, mixed mode) Any advice on how to proceed here? Thanks, --Ben