Thanks Joseph and Sean! I did give it a quick try with override approach, then 'riak-admin ensemble-status' did return enabled/active...but when I try to insert a new entry the server just crashed. After few trials and server restart, the setting somehow got auto reverted back. Now I am back w/ non-consistent bucket type and it works fine.
One thing that I did notice is that when I insert an entry into a bucket through java client, I can see the new entry in the bucket through http curl cmd immediately, BUT not getting the newly entry key/id through solr query. I wonder if there is a setting that I can tune to sorta of make the solr indexing real-time? Thanks. On Mon, Jul 28, 2014 at 8:52 PM, Sean Cribbs <[email protected]> wrote: > Furthermore, you should almost never use the 'ASIS' option. It does not > mean what you think it means (and probably means nothing to strong > consistency). > > > On Mon, Jul 28, 2014 at 6:55 PM, Joseph Blomstedt <[email protected]> wrote: > >> This means the consistency sub-system is not enabled/active. You can >> verify this with the output of `riak-admin ensemble-status`. >> >> To enable strong consistency you must: >> >> 1) Set 'strong_consistency = on' in riak.conf. >> 2) Have at least a 3 node cluster. >> >> You can address #2 by setting up 3+ local developer nodes as detailed >> in the 5 minute tutorial: >> http://docs.basho.com/riak/2.0.0/quickstart >> >> Alternatively, you can override the need for 3 nodes and use 1 node. >> >> To do that, >> >> 1) Run 'riak attach' to attach to your Riak's node console >> 2) Enter (including the period): riak_ensemble_manager:enable(). >> 3) Enter (including the period): riak_core_ring_manager:force_update(). >> 3) Detach from the console using: Ctrl-C a >> >> After either approach, re-check `riak-admin ensemble-status`. It may >> take up to a minute for the consistency sub-system to be enabled. >> >> If you haven't already, please take a look at the temporary (until we >> finish updating docs.basho.com) strong consistency related >> documentation (linked from the 2.0 RC1 release notes) here: >> >> https://github.com/basho/riak_ensemble/blob/wip/riak-2.0-user-docs/riak_consistent_user_docs.md >> >> Regards, >> Joe >> >> On Mon, Jul 28, 2014 at 3:05 PM, Jason W <[email protected]> wrote: >> > Hi, >> > >> > I am trying out 2.0 w/ just one local node, created a strongly >> consistent >> > bucket type. But keep getting below exception. If I just use the >> default >> > bucket type, everything works fine. Here is the bucket type detail with >> > consistency bit on. >> > >> > young_vclock: 20 >> > w: quorum >> > small_vclock: 50 >> > rw: quorum >> > r: quorum >> > pw: 0 >> > precommit: [] >> > pr: 0 >> > postcommit: [] >> > old_vclock: 86400 >> > notfound_ok: true >> > n_val: 1 >> > linkfun: {modfun,riak_kv_wm_link_walker,mapreduce_linkfun} >> > last_write_wins: false >> > dw: quorum >> > dvv_enabled: true >> > chash_keyfun: {riak_core_util,chash_std_keyfun} >> > big_vclock: 50 >> > basic_quorum: false >> > allow_mult: true >> > consistent: true >> > active: true >> > claimant: '[email protected]' >> > >> > Here is the java code >> > >> > List<String> addresses = new LinkedList<String>(); >> > >> > addresses.add("172.16.0.254"); >> > >> > RiakClient riakClient = RiakClient.newClient(addresses); >> > >> > try { >> > >> > Location wildeGeniusQuote = new Location(new >> > Namespace("strongly_consistent2", "sample"), emp.getId()); >> > >> > BinaryValue text = >> > BinaryValue.create(objectMapper.writeValueAsBytes(sampleObj)); >> > >> > RiakObject obj = new RiakObject() >> > >> > .setContentType("text/plain") >> > >> > .setValue(text); >> > >> > StoreValue store = new >> > StoreValue.Builder(obj).withLocation(wildeGeniusQuote) >> > >> > .withOption(Option.ASIS, true) >> > >> > .withOption(Option.DW, new Quorum(1)) >> > >> > .withOption(Option.IF_NONE_MATCH, true) >> > >> > .withOption(Option.IF_NOT_MODIFIED, true) >> > >> > .withOption(Option.PW, new Quorum(1)) >> > >> > .withOption(Option.N_VAL, 1) >> > >> > .withOption(Option.RETURN_BODY, true) >> > >> > .withOption(Option.RETURN_HEAD, true) >> > >> > .withOption(Option.SLOPPY_QUORUM, true) >> > >> > .withOption(Option.TIMEOUT, 1000) >> > >> > .withOption(Option.W, new Quorum(1)) >> > >> > .build(); >> > >> > riakClient.execute(store); >> > >> > } catch (Exception e) { >> > >> > e.printStackTrace(); >> > >> > return null; >> > >> > } >> > >> > Am I still missing something? Thanks. >> > >> > >> > >> > Caused by: com.basho.riak.client.core.netty.RiakResponseException: >> > unavailable >> > >> > at >> > >> com.basho.riak.client.core.netty.RiakResponseHandler.channelRead(RiakResponseHandler.java:52) >> > >> > at >> > >> io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:340) >> > >> > at >> > >> io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:326) >> > >> > at >> > >> io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:155) >> > >> > at >> > >> io.netty.handler.codec.ByteToMessageCodec.channelRead(ByteToMessageCodec.java:108) >> > >> > at >> > >> io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:340) >> > >> > at >> > >> io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:326) >> > >> > at >> > >> io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:785) >> > >> > at >> > >> io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:116) >> > >> > at >> > >> io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:494) >> > >> > at >> > >> io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:461) >> > >> > at >> > >> io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:378) >> > >> > at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:350) >> > >> > at >> > >> io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101) >> > >> > ... 1 more >> > >> > >> > _______________________________________________ >> > riak-users mailing list >> > [email protected] >> > http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com >> > >> >> >> >> -- >> Joseph Blomstedt <[email protected]> >> Principal Engineer >> Basho Technologies, Inc. >> http://www.basho.com/ >> >> _______________________________________________ >> riak-users mailing list >> [email protected] >> http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com >> > > > > -- > Sean Cribbs <[email protected]> > Software Engineer > Basho Technologies, Inc. > http://basho.com/ >
_______________________________________________ riak-users mailing list [email protected] http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com
