Skip to content

Instantly share code, notes, and snippets.

View zzt93's full-sized avatar

Tony Zeng zzt93

View GitHub Profile
org.elasticsearch.indices.recovery.RecoveryFailedException: [role-2915][0]: Recovery failed on {ubuntu-200}{QWjjPXyySuWh7npiB6RXFA}{z6fNZHM6QTy-k-oOWinKkg}{192.168.1.200}{192.168.1.200:9300}{ml.max_open_jobs=10, ml.enabled=true}
at org.elasticsearch.index.shard.IndexShard.lambda$startRecovery$1(IndexShard.java:1488) ~[elasticsearch-5.6.1.jar:5.6.1]
at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:569) ~[elasticsearch-5.6.1.jar:5.6.1]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) ~[?:1.8.0_45]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) ~[?:1.8.0_45]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_45]
Caused by: org.elasticsearch.index.shard.IndexShardRecoveryException: failed to fetch index version after copying it over
at org.elasticsearch.index.shard.StoreRecovery.internalRecoverFromStore(StoreRecovery.java:344) ~[elasticsearch-5.6.1.jar:5.6.1]
at org.elasticsearch.i
[2017-11-02T10:35:44,801][ERROR][i.n.u.c.D.rejectedExecution] Failed to submit a listener notification task. Event loop shut down?
java.util.concurrent.RejectedExecutionException: event executor terminated
at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:821) ~[?:?]
at io.netty.util.concurrent.SingleThreadEventExecutor.offerTask(SingleThreadEventExecutor.java:327) ~[?:?]
at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:320) ~[?:?]
at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:746) ~[?:?]
at io.netty.util.concurrent.DefaultPromise.safeExecute(DefaultPromise.java:760) ~[?:?]
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:428) ~[?:?]
at io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:163) ~[?:?]
at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:93) ~[?:?]
Exception in thread "[main]>worker7" java.lang.NullPointerException
at org.logstash.DateNode.evaluate(DateNode.java:21)
at org.logstash.Template.evaluate(Template.java:28)
at org.logstash.StringInterpolation.evaluate(StringInterpolation.java:47)
at org.logstash.Event.sprintf(Event.java:289)
at org.logstash.ext.JrubyEventExtLibrary$RubyEvent.ruby_sprintf(JrubyEventExtLibrary.java:203)
at org.logstash.ext.JrubyEventExtLibrary$RubyEvent$INVOKER$i$1$0$ruby_sprintf.call(JrubyEventExtLibrary$RubyEvent$INVOKER$i$1$0$ruby_sprintf.gen)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:168)
at org.jruby.ast.CallOneArgNode.interpret(CallOneArgNode.java:57)
at org.jruby.ast.DAsgnNode.interpret(DAsgnNode.java:110)
[2017-10-31T09:16:22,432][ERROR][o.e.t.n.Netty4Utils ] fatal error on the network layer
at org.elasticsearch.transport.netty4.Netty4Utils.maybeDie(Netty4Utils.java:179)
at org.elasticsearch.transport.netty4.Netty4MessageChannelHandler.exceptionCaught(Netty4MessageChannelHandler.java:83)
at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
at io.netty.channel.AbstractChannelHandlerContext.notifyHandlerException(AbstractChannelHandlerContext.java:850)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:364)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMes
@zzt93
zzt93 / latency.txt
Last active March 15, 2017 01:59 — forked from jboner/latency.txt
Latency Numbers Every Programmer Should Know
Latency Comparison Numbers
--------------------------
L1 cache reference 0.5 ns
Branch mispredict 5 ns
L2 cache reference 7 ns 14x L1 cache
Mutex lock/unlock 25 ns
Main memory reference 100 ns 20x L2 cache, 200x L1 cache
Compress 1K bytes with Zippy 3,000 ns 3 us
Send 1K bytes over 1 Gbps network 10,000 ns 10 us
Read 4K randomly from SSD* 150,000 ns 150 us ~1GB/sec SSD
vector<int> getNext(const string& s) {
vector<int> res(s.length());
res[0] = -1;
const char* start = s.c_str();
int j = -1;
for(int i = 0; i < s.length() - 1; ) {
if(j == -1) {
res[i + 1] = 0;
i++;
j = 0;
@zzt93
zzt93 / LongestPalindromic.java
Created July 7, 2016 11:47
A solution for longest palindromic problem and used to learn profiling
package interview.leetcode;
import competition.utility.MyIn;
import java.util.ArrayList;
/**
* Created by zzt on 7/6/16.
* <p>
* <h3></h3>
@zzt93
zzt93 / prime.c
Created June 4, 2016 08:03
Code sample to learn pthread and performance tuning
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <math.h>
#include "prime.h"
void prime(long long n) {
// too large n cause stack overflow
size_t mem = sizeof(int)*(n + 1);
#include <stdio.h>
#include <stdarg.h>
void hello2(int p1, int p2)
{
printf("hello2 %d %d\n", p1, p2);
}
void hello3(int p1, int p2, int p3)
{
#include "var.h"
#include <stdio.h>
#define hello1(s) hello2(s, "default string")
void hello2(const char *s, const char* s2) {
printf("hello2 %s and %s\n", s, s2);
}
#define hello(...) xglue(hello, PP_NARG(__VA_ARGS__))(__VA_ARGS__)