cdahlqvist

{ "index" : { "_index" : "test", "_type" : "type1" } }
{ "field1" : "value1" }
{ "create" : { "_index" : "test", "_type" : "type1" } }
{ "field1" : "value3" }

cdahlqvist

Code samples for X-Pack enablement

Watcher, Step 3-1

PUT _watcher/watch/manage_history
{
    "metadata": {
        "keep_history_days": 2
    },

cdahlqvist

The provided index template loading script works fine on ES 5.0.0-alpha4 but fails on ES 5.0.0-alpha5 with the following error message.

[2016-09-06 02:52:45,093][WARN ][http.netty4              ] [ECKV_Vw] caught exception while handling client http traffic, closing connection [id: 0x1ecebe60, L:/127.0.0.1:9200 - R:/127.0.0.1:64769]
java.lang.UnsupportedOperationException: unsupported message type: DefaultFullHttpResponse (expected: ByteBuf, FileRegion)
	at io.netty.channel.nio.AbstractNioByteChannel.filterOutboundMessage(AbstractNioByteChannel.java:260)
	at io.netty.channel.AbstractChannel$AbstractUnsafe.write(AbstractChannel.java:799)
	at io.netty.channel.DefaultChannelPipeline$HeadContext.write(DefaultChannelPipeline.java:1291)
	at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:748)
	at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:811)
	at io.netty.channel.AbstractChannelHandlerContext.write(AbstractCh

cdahlqvist

{
   "@timestamp": "2016-01-29T16:18:30.574Z",
   "referrer": "https://www.elastic.co/guide/en/elasticsearch/reference/current/mapping.html",
   "verb": "GET",
   "request": "/assets/blt6892ef667f7c28d7/icon-elasticsearch2.svg",
   "geoip": {
      "location": [87.3333, 22.3333],
      "country_name": "India"
   },
   "agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_11_4) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/48.0.2564.97 Safari/537.36",

cdahlqvist

#!/usr/bin/env perl
use LWP;
use HTTP::Request::Common;

my $url = "localhost:9200";
my $protocol = "http";

my $index_name_prefix = "shardtest";
my $counter = 0;
my $indexspec = '{"settings":{"index":{"number_of_shards":"100","number_of_replicas":"0"}}}';

cdahlqvist

#!/usr/bin/env escript

main(Args) ->

	% - From nodetool ------------------------------------------------------- %

	{_, TargetNode} = process_args(Args, [], undefined),

	case {net_kernel:connect_node(TargetNode), net_adm:ping(TargetNode)} of
        {true, pong} ->

cdahlqvist

-module(robin_handoff).

-export([start/0,start/1,start/2,stop/0]).
-export([step/0]).


%% see if a handoff is in progress

active_count(Node) when is_atom(Node) ->
	Receivers=rpc:call(Node,supervisor,count_children,[riak_core_handoff_receiver_sup]),

cdahlqvist

This is an erlang snippet to be run from a riak attach session

After pasting the following into the attach session, to repair all riak_kv partitions, run

RepairProc = RepairAllKv(60).

or, to repair all riak_search partitions, run

RepairProc = RepairAllSearch(60).

cdahlqvist

#!/usr/bin/env escript
%% -*- erlang -*-

-include_lib("kernel/include/file.hrl").
-compile(export_all).
-define(LOG(S), io:format(S)).
-define(LOG(S,A), io:format(S,A)).

main(Dirs) ->
    CodePath = case os:getenv("RIAK_LIB") of

cdahlqvist

%% -------------------------------------------------------------------
%%
%% pb_status_monitor: PoolBoy pool monitor
%%
%% Copyright (c) 2013 Basho Technologies, Inc. All Rights Reserved.
%%
%% This file is provided to you under the Apache License,
%% Version 2.0 (the "License"); you may not use this file
%% except in compliance with the License.  You may obtain
%% a copy of the License at