Rebalancing Cassandra 1.2 cluster when a seed node (from total of 2) is died using virtual nodes -

-

i have cassandra 1.2 cluster in local machine modified hosts:

#cassandra nodes m.y.i.p               m.y.i.p   (node 1)<---- seed 1 m.y.i.p               127.0.0.3 (node 2) m.y.i.p               127.0.0.4 (node 3)<---- seed 2 m.y.i.p               127.0.0.5 (node 4) m.y.i.p               127.0.0.6 (node 5)

... cluster has total of 5 nodes. i'm using virtual nodes, don't havo set initial_token anywhere.

the steps i've followed:

  1. start seed nodes (1 , 3)
  2. start nodes 2 , 4.
  3. turn off node 3.
  4. try join node 5.

the problem in 4th step, when try join node 5 cassandra throws exception:

   java.lang.illegalstateexception: unable find sufficient sources streaming range (-7204018021044318047,-6965052533844316617]         @ org.apache.cassandra.dht.rangestreamer.getrangefetchmap(rangestreamer.java:205)         @ org.apache.cassandra.dht.rangestreamer.addranges(rangestreamer.java:129)         @ org.apache.cassandra.dht.bootstrapper.bootstrap(bootstrapper.java:81)         @ org.apache.cassandra.service.storageservice.bootstrap(storageservice.java:890)         @ org.apache.cassandra.service.storageservice.jointokenring(storageservice.java:659)         @ org.apache.cassandra.service.storageservice.initserver(storageservice.java:514)         @ org.apache.cassandra.service.storageservice.initserver(storageservice.java:411)         @ org.apache.cassandra.service.cassandradaemon.setup(cassandradaemon.java:278)         @ org.apache.cassandra.service.cassandradaemon.activate(cassandradaemon.java:366)         @ org.apache.cassandra.service.cassandradaemon.main(cassandradaemon.java:409) java.lang.illegalstateexception: unable find sufficient sources streaming range (-7204018021044318047,-6965052533844316617]         @ org.apache.cassandra.dht.rangestreamer.getrangefetchmap(rangestreamer.java:205)         @ org.apache.cassandra.dht.rangestreamer.addranges(rangestreamer.java:129)         @ org.apache.cassandra.dht.bootstrapper.bootstrap(bootstrapper.java:81)         @ org.apache.cassandra.service.storageservice.bootstrap(storageservice.java:890)         @ org.apache.cassandra.service.storageservice.jointokenring(storageservice.java:659)         @ org.apache.cassandra.service.storageservice.initserver(storageservice.java:514)         @ org.apache.cassandra.service.storageservice.initserver(storageservice.java:411)         @ org.apache.cassandra.service.cassandradaemon.setup(cassandradaemon.java:278)         @ org.apache.cassandra.service.cassandradaemon.activate(cassandradaemon.java:366)         @ org.apache.cassandra.service.cassandradaemon.main(cassandradaemon.java:409) exception encountered during startup: unable find sufficient sources streaming range (-7204018021044318047,-6965052533844316617] error 16:55:47,634 exception in thread thread[storageserviceshutdownhook,5,main] java.lang.nullpointerexception         @ org.apache.cassandra.service.storageservice.stoprpcserver(storageservice.java:321)         @ org.apache.cassandra.service.storageservice$1.runmaythrow(storageservice.java:479)         @ org.apache.cassandra.utils.wrappedrunnable.run(wrappedrunnable.java:28)         @ java.lang.thread.run(thread.java:722)

the range (-7204018021044318047,-6965052533844316617] belongs died node (node 3). due i'm using virtual nodes, think ring must rebalance:

rebalancing cluster no longer necessary when adding or removing nodes. when node joins cluster, assumes responsibility portion of data other nodes in cluster. if node fails, load spread evenly across other nodes in cluster.

but i'm wrong, :).

what can join new node in existing cluster when previous node down? please, note have 256 tokens per node, nodetool move isn't option (i think).

thank in advance, info welcome!

the solution remove node 3 (which turned off) token manually.


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

c - Unrecognised emulation mode: elf_i386 on MinGW32 -

-
i'm trying make kernel, , cannot link c output assembly. ld . i'm getting error: unrecognized emulation mode: elf_i386 i'm using windows 10 professional mingw32 , msys. code using: link.ld /* * link.ld */ output_format(elf32-i386) entry(start) sections { . = 0x100000; .text : { *(.text) } .data : { *(.data) } .bss : { *(.bss) } } kernel.c /* * kernel.c */ void kmain(void) { const char *str = "my first kernel"; char *vidptr = (char*)0xb8000; //video mem begins here. unsigned int = 0; unsigned int j = 0; /* loops clears screen * there 25 lines each of 80 columns; each element takes 2 bytes */ while(j < 80 * 25 * 2) { /* blank character */ vidptr[j] = ' '; /* attribute-byte - light grey on black screen */ vidptr[j+1] = 0x07; j = j + 2; } j = 0; /* loop writes string video memory */ while(str[j] != '\0') { /
Read more