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