cassandra - Hadoop jar submission error java.lang.InstantiationException -


i'm trying run jar on hadoop filesystem getting exception see image

exception stacktrace

my code running if run eclipse.

here runner main class

    public class readcassandra extends configured implements tool{          public static void main(string args[]){             try{                 /*toolrunner.run(new configuration(),new readcassandra(), args);                 system.exit(0);*/                  string keyspace ="read_log";                 string clg ="readvalidpost";                 string rowkey="117761667160131";                 list<bytebuffer> cn = new arraylist<bytebuffer>();                 list<string> cl = new arraylist<string>();                 cl.addall(myhector.getcolumn(rowkey));                 (string string : cl) {                     bytebuffer bf = bytebufferutil.bytes(string);                     cn.add(bf);                 }                 configuration conf = new configuration();                 job job = new job(conf,"mejfsd");                 //job.setjarbyclass(readcassandra.class);                  job.setinputformatclass(abstractcolumnfamilyinputformat.class);                 job.setoutputformatclass(textoutputformat.class);                  job.setoutputkeyclass(text.class);                 job.setoutputvalueclass(text.class);                  job.setmapperclass(mymapper.class);                 job.setreducerclass(myreducer.class);                  confighelper.setinputrpcport(job.getconfiguration(), "9160");                 confighelper.setinputinitialaddress(job.getconfiguration(), "127.0.0.1");                 confighelper.setinputpartitioner(job.getconfiguration(), "org.apache.cassandra.dht.murmur3partitioner");                 confighelper.setinputcolumnfamily(job.getconfiguration(), keyspace, clg);                  slicepredicate predicate = new slicepredicate().setcolumn_names(cn);                 confighelper.setinputslicepredicate(job.getconfiguration(), predicate);                  filesystem.get(job.getconfiguration()).delete(new path("output"), true);                 fileoutputformat.setoutputpath(job, new path("output"));                 job.waitforcompletion(true);              }catch(exception e){                 e.printstacktrace();             }         }          public int run(string[] arg0) throws exception {               return (1);         }       }

i'm running using command 

hadoop jar /home/winoria/documents/jarfiles/readcas.jar readcassandra

you setting input format class abstract class:

 job.setinputformatclass(abstractcolumnfamilyinputformat.class);

you need set instantiate-able. don't know cassandra-hadoop integration , makes sense in case. make sure not abstract class.


Comments

Post a Comment

Popular posts from this blog

Android layout hidden on keyboard show -

i have strange problem layout. when tap on edittext , keyboard shown edittext stay on bottom , when tap on to hide keyboard , keyboard hides , edittext go should when want input text. when tap again, keyboard shown , edittext goes down behind keyboard... <relativelayout android:layout_width="match_parent" android:layout_height="match_parent" > <scrollview android:layout_width="match_parent" android:layout_height="fill_parent" android:above="@+id/rl_commands"> <textview android:layout_width="match_parent" android:layout_height="wrap_content"/> </scrollview> <relativelayout android:layout_width="match_parent android:layout_height="24dp" android:id="@+id/rl_commands" android:alignparentbottom="true">
Read more

google app engine - 403 Forbidden POST - Flask WTForms -

i have flask application running on google app engine. trying submit form built using wtform , keep getting following error. 403 forbidden: don't have permission access requested resource. either read-protected or not readable server. location.html (part of code) <form method=post action="/home/location"> .... <button type="submit" class="btn btn-primary" value="submit"> directions </button> </form> main.py @app.route('/home/location', methods=['post', 'get']) def location(): form = cfcdirections.direction(request.form) print(request.method) if request.method == 'post' , form.validate(): print("after if") directions = cfcdirections() street_no = directions.no street = directions.street suburb = directions.suburb postcode = directions.postcode
Read more

c - Why would PK11_GenerateRandom() return an error -8023? -

i looking through internet trying find source of pk11_generaterandom() function see why function fail. have program uses function when moved new flavor of linux, fails after forking ( fork() ) since not believe there problem nss, suspect doing incorrectly disregarded in older versions of linux new 1 there issue. the openssl package same on 'good' , 'bad' server: openssl 0.9.8e-fips-rhel5 01 jul nss rpm differs though. 'good' has nss-3.12.2.0-2.el5 and bas has version nss-3.15.3-4.el5_10 the 'good' server uses quite obsolete linux: linux 2.6.18-128.el5 #1 smp wed jan 21 08:45:05 est 2009 x86_64 x86_64 x86_64 gnu/linux enterprise linux enterprise linux server release 5.3 (carthage) red hat enterprise linux server release 5.3 (tikanga) the 'bad' server newer: linux bad 2.6.18-371.4.1.el5 #1 smp wed jan 29 11:05:49 pst 2014 x86_64 x86_64 x86_64 gnu/linux oracle linux server release 5.10 red hat enterprise linux server release
Read more