This discussion is archived
3 Replies Latest reply: Mar 4, 2013 7:30 AM by 918307 RSS

Re: Oracle NoSQL & Hadoop

987122 Newbie
Currently Being Moderated
Hi

I have installed Oracle NoSQL Database 11gR2.2.0.23 Enterprise Edition on /u01/app/oracle/product/kv-2.0.23 and addeed a few key-value pairs to the kvstore

Then I went to run the example that comes with the NoSQL binaries called "CountMinorKeys.java" (located at /u01/app/oracle/product/kv-2.0.23/examples/hadoop)

I am using CDH 4.1 Community Edition.

When I run the java class "CountMinorKeys.java" it throws the following error

[admin@vm224 hadoop]$ hadoop jar hadoopSamples.jar hadoop.CountMinorKeys kvstore vm223.escaja.com:5000 /user/admin/CountMinorKeys/output/test01
13/01/15 11:40:35 WARN mapred.JobClient: Use GenericOptionsParser for parsing the arguments. Applications should implement Tool for the same.
13/01/15 11:40:35 INFO mapred.JobClient: Cleaning up the staging area hdfs://vm224.escaja.com:8020/user/admin/.staging/job_201301150717_0007
Exception in thread "main" java.lang.IncompatibleClassChangeError: Found interface org.apache.hadoop.mapreduce.JobContext, but class was expected
at oracle.kv.hadoop.KVInputFormatBase.getSplits(KVInputFormatBase.java:184)
at org.apache.hadoop.mapred.JobClient.writeNewSplits(JobClient.java:1014)
at org.apache.hadoop.mapred.JobClient.writeSplits(JobClient.java:1031)
at org.apache.hadoop.mapred.JobClient.access$600(JobClient.java:172)
at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:943)
at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:896)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:396)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1332)
at org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient.java:896)
at org.apache.hadoop.mapreduce.Job.submit(Job.java:531)
at org.apache.hadoop.mapreduce.Job.waitForCompletion(Job.java:561)
at hadoop.CountMinorKeys.run(CountMinorKeys.java:110)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:84)
at hadoop.CountMinorKeys.main(CountMinorKeys.java:117)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.apache.hadoop.util.RunJar.main(RunJar.java:208)