java - Cassandra NoHostAvailableException caused by DriverException while traversing a resultset -

-

i getting error repeatedly while traversing resultset of size 100,000 . have used 

.withreconnectionpolicy(new constantreconnectionpolicy(1000))                 .withretrypolicy(defaultretrypolicy.instance)                 .withqueryoptions(new queryoptions().setfetchsize(2000))

in connector. still getting error. typically fails after fetching 80000 rows.

com.datastax.driver.core.exceptions.nohostavailableexception: host(s) tried query failed (tried: /172.16.12.143:9042 (com.datastax.driver.core.exceptions.driverexception: timed out waiting server response), /172.16.12.141:9042 (com.datastax.driver.core.exceptions.driverexception: timed out waiting server response)) @ com.datastax.driver.core.exceptions.nohostavailableexception.copy(nohostavailableexception.java:65) @ com.datastax.driver.core.defaultresultsetfuture.extractcausefromexecutionexception(defaultresultsetfuture.java:259) @ com.datastax.driver.core.defaultresultsetfuture.getuninterruptibly(defaultresultsetfuture.java:175) @ com.datastax.driver.core.abstractsession.execute(abstractsession.java:52) @ com.payu.merchantanalytics.funnelhourlyutilcql.groupbyhourcql(funnelhourlyutilcql.java:87) @ com.payu.merchantanalytics.funnelhourlyutilcql.main(funnelhourlyutilcql.java:49) @ sun.reflect.nativemethodaccessorimpl.invoke0(native method) @ sun.reflect.nativemethodaccessorimpl.invoke(nativemethodaccessorimpl.java:62) @ sun.reflect.delegatingmethodaccessorimpl.invoke(delegatingmethodaccessorimpl.java:43) @ java.lang.reflect.method.invoke(method.java:497) @ org.apache.spark.deploy.worker.driverwrapper$.main(driverwrapper.scala:58) @ org.apache.spark.deploy.worker.driverwrapper.main(driverwrapper.scala) caused by: com.datastax.driver.core.exceptions.nohostavailableexception: host(s) tried query failed (tried: /172.16.12.143:9042 (com.datastax.driver.core.exceptions.driverexception: timed out waiting server response), /172.16.12.141:9042 (com.datastax.driver.core.exceptions.driverexception: timed out waiting server response)) @ com.datastax.driver.core.requesthandler.sendrequest(requesthandler.java:108) @ com.datastax.driver.core.requesthandler$1.run(requesthandler.java:179) @ java.util.concurrent.threadpoolexecutor.runworker(threadpoolexecutor.java:1142) @ java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor.java:617) @ java.lang.thread.run(thread.java:745)

solved thanks andy tolbert answer. setting readtimeoutmillis using socketoptions.setreadtimeoutmillis(100000) worked.

now code looks :-

socketoptions socketoptions = new socketoptions().setreadtimeoutmillis(100000); cluster.builder()                 .addcontactpoints(nodes)                 .withreconnectionpolicy(new constantreconnectionpolicy(1000))                 .withretrypolicy(defaultretrypolicy.instance)                 .withqueryoptions(new queryoptions().setfetchsize(2000))                 .withsocketoptions(socketoptions)                 .withcredentials(username, password).build();

thanks lot :)


Comments

Post a Comment

Popular posts from this blog

ruby - Trying to change last to "x"s to 23 -

-
i have been playing around irb , have string looks this: irb(main):072:0> puts ["[\"4354 5432 5432 xxxxx\", \"6547 6547 8543 xxxxx\", \"2344 6543 6674 xxxxx\", \"2346 6236 7543 xxxxx\", \"1273 5585 5587 xxxxx\"]"] => nil irb(main):073:0> what want gsub last 2 "x" s of each 17 digit combination, 23 . what i've tried far (i've been using rubular): a.gsub(/\d[x]/,"23") <= grabs "x" s i'm close a.gsub(/\w[x{2}]/,"23") <= grabs "x" s grabs two digits each combination. is there easier way i'm not understanding? a.gsub(/\d{4} \d{4} \d{4} xxx\kxx/, '23') \d{4} = 4 digits what \k drop matched far. can use don't replace entire number, still able validate have in desired format.
Read more

jquery - Clone last and append item to closest class -

-
this bare-bones code on page: <div class="list-container"> <div class="single-list-item"> <button>remove</button> </div> <div class="single-list-item"> <button>remove</button> </div> <div class="single-list-item"> <button>remove</button> </div> </div> <p><button class="add-list-item">add</button></p> <div class="list-container"> <div class="single-list-item"> <button>remove</button> </div> <div class="single-list-item"> <button>remove</button> </div> <div class="single-list-item"> <button>remove</button> </div> </div> <p><button class="add-list-item">add</button></p> <di...
Read more

css - Can I use the :after pseudo-element on an input field? -

-
i trying use :after css pseudo-element on input field, not work. if use span , works ok. <style type="text/css"> .mystyle:after {content:url(smiley.gif);} .mystyle {color:red;} </style> this works (puts smiley after "buu!" , before "some more") <span class="mystyle">buuu!</span>a more this not work - colors somevalue in red, there no smiley. <input class="mystyle" type="text" value="somevalue"> what doing wrong? should use pseudo-selector? note: cannot add span around input , because being generated third-party control. :after , :before not supported in internet explorer 7 , under, on elements. it's not meant used on replaced elements such form elements (inputs) , image elements . in other words it's impossible pure css. however if using jquery can use $(".mystyle").after("add smiley here"); api docs on .after to ...
Read more