Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
月轩居士
SkyWalking
提交
87eb1e9c
S
SkyWalking
项目概览
月轩居士
/
SkyWalking
与 Fork 源项目一致
Fork自
apache / SkyWalking
通知
4
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
S
SkyWalking
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
87eb1e9c
编写于
6月 05, 2017
作者:
wu-sheng
提交者:
GitHub
6月 05, 2017
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #207 from wu-sheng/fix/203
Fixed bug #203.
上级
30b79503
b019d35f
变更
14
展开全部
隐藏空白更改
内联
并排
Showing
14 changed file
with
1600 addition
and
44 deletion
+1600
-44
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/httpserver/AbstractPost.java
.../skywalking/collector/worker/httpserver/AbstractPost.java
+3
-3
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/GlobalTraceId.java
...alking/collector/worker/segment/entity/GlobalTraceId.java
+2
-4
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/LogData.java
...e/skywalking/collector/worker/segment/entity/LogData.java
+2
-4
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/Segment.java
...e/skywalking/collector/worker/segment/entity/Segment.java
+7
-9
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/SegmentDeserialize.java
...g/collector/worker/segment/entity/SegmentDeserialize.java
+3
-5
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/SegmentJsonReader.java
...ng/collector/worker/segment/entity/SegmentJsonReader.java
+1505
-0
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/SegmentJsonScope.java
...ing/collector/worker/segment/entity/SegmentJsonScope.java
+55
-0
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/Span.java
.../eye/skywalking/collector/worker/segment/entity/Span.java
+3
-5
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/TraceSegmentRef.java
...king/collector/worker/segment/entity/TraceSegmentRef.java
+4
-5
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/storage/PersistenceTimer.java
...skywalking/collector/worker/storage/PersistenceTimer.java
+1
-1
skywalking-collector/skywalking-collector-worker/src/main/resources/log4j2.xml
...skywalking-collector-worker/src/main/resources/log4j2.xml
+1
-1
skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/segment/entity/LogDataTestCase.java
...king/collector/worker/segment/entity/LogDataTestCase.java
+1
-2
skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/segment/entity/TraceSegmentRefTestCase.java
...lector/worker/segment/entity/TraceSegmentRefTestCase.java
+1
-2
skywalking-collector/skywalking-collector-worker/src/test/resources/json/segment/post/normal/cache-service.json
...est/resources/json/segment/post/normal/cache-service.json
+12
-3
未找到文件。
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/httpserver/AbstractPost.java
浏览文件 @
87eb1e9c
...
...
@@ -6,8 +6,8 @@ import com.a.eye.skywalking.collector.actor.LocalAsyncWorkerRef;
import
com.a.eye.skywalking.collector.actor.LocalWorkerContext
;
import
com.a.eye.skywalking.collector.actor.Role
;
import
com.a.eye.skywalking.collector.worker.segment.entity.Segment
;
import
com.a.eye.skywalking.collector.worker.segment.entity.SegmentJsonReader
;
import
com.google.gson.JsonObject
;
import
com.google.gson.stream.JsonReader
;
import
java.io.BufferedReader
;
import
java.io.IOException
;
import
javax.servlet.ServletException
;
...
...
@@ -57,12 +57,12 @@ public abstract class AbstractPost extends AbstractLocalAsyncWorker {
}
private
void
streamReader
(
BufferedReader
bufferedReader
)
throws
Exception
{
try
(
JsonReader
reader
=
new
JsonReader
(
bufferedReader
))
{
try
(
SegmentJsonReader
reader
=
new
Segment
JsonReader
(
bufferedReader
))
{
readSegmentArray
(
reader
);
}
}
private
void
readSegmentArray
(
JsonReader
reader
)
throws
Exception
{
private
void
readSegmentArray
(
Segment
JsonReader
reader
)
throws
Exception
{
reader
.
beginArray
();
while
(
reader
.
hasNext
())
{
Segment
segment
=
new
Segment
();
...
...
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/GlobalTraceId.java
浏览文件 @
87eb1e9c
package
com.a.eye.skywalking.collector.worker.segment.entity
;
import
com.google.gson.stream.JsonReader
;
import
java.io.IOException
;
/**
...
...
@@ -14,8 +12,8 @@ public class GlobalTraceId extends DeserializeObject {
return
globalTraceId
;
}
public
GlobalTraceId
deserialize
(
JsonReader
reader
)
throws
IOException
{
this
.
globalTraceId
=
reader
.
nextString
();
public
GlobalTraceId
deserialize
(
Segment
JsonReader
reader
)
throws
IOException
{
this
.
globalTraceId
=
reader
.
nextString
()
.
getValue
()
;
this
.
setJsonStr
(
"\""
+
globalTraceId
+
"\""
);
return
this
;
}
...
...
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/LogData.java
浏览文件 @
87eb1e9c
package
com.a.eye.skywalking.collector.worker.segment.entity
;
import
com.google.gson.stream.JsonReader
;
import
java.io.IOException
;
import
java.util.HashMap
;
import
java.util.Map
;
...
...
@@ -21,7 +19,7 @@ public class LogData extends DeserializeObject {
return
fields
;
}
public
LogData
deserialize
(
JsonReader
reader
)
throws
IOException
{
public
LogData
deserialize
(
Segment
JsonReader
reader
)
throws
IOException
{
StringBuilder
stringBuilder
=
new
StringBuilder
();
stringBuilder
.
append
(
"{"
);
...
...
@@ -40,7 +38,7 @@ public class LogData extends DeserializeObject {
while
(
reader
.
hasNext
())
{
String
key
=
reader
.
nextName
();
String
value
=
reader
.
nextString
();
String
value
=
reader
.
nextString
()
.
getOriginValue
()
;
fields
.
put
(
key
,
value
);
}
reader
.
endObject
();
...
...
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/Segment.java
浏览文件 @
87eb1e9c
package
com.a.eye.skywalking.collector.worker.segment.entity
;
import
com.google.gson.stream.JsonReader
;
import
java.io.IOException
;
import
java.util.ArrayList
;
import
java.util.List
;
...
...
@@ -46,7 +44,7 @@ public class Segment extends DeserializeObject {
return
relatedGlobalTraces
;
}
public
Segment
deserialize
(
JsonReader
reader
)
throws
IOException
{
public
Segment
deserialize
(
Segment
JsonReader
reader
)
throws
IOException
{
StringBuilder
stringBuilder
=
new
StringBuilder
();
stringBuilder
.
append
(
"{"
);
...
...
@@ -55,14 +53,14 @@ public class Segment extends DeserializeObject {
while
(
reader
.
hasNext
())
{
switch
(
reader
.
nextName
())
{
case
"ts"
:
S
tring
ts
=
reader
.
nextString
();
this
.
traceSegmentId
=
ts
;
JsonBuilder
.
INSTANCE
.
append
(
stringBuilder
,
"ts"
,
ts
,
first
);
S
egmentJsonReader
.
StringValue
ts
=
reader
.
nextString
();
this
.
traceSegmentId
=
ts
.
getValue
()
;
JsonBuilder
.
INSTANCE
.
append
(
stringBuilder
,
"ts"
,
ts
.
getOriginValue
()
,
first
);
break
;
case
"ac"
:
S
tring
ac
=
reader
.
nextString
();
this
.
applicationCode
=
ac
;
JsonBuilder
.
INSTANCE
.
append
(
stringBuilder
,
"ac"
,
ac
,
first
);
S
egmentJsonReader
.
StringValue
ac
=
reader
.
nextString
();
this
.
applicationCode
=
ac
.
getValue
()
;
JsonBuilder
.
INSTANCE
.
append
(
stringBuilder
,
"ac"
,
ac
.
getOriginValue
()
,
first
);
break
;
case
"st"
:
long
st
=
reader
.
nextLong
();
...
...
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/SegmentDeserialize.java
浏览文件 @
87eb1e9c
package
com.a.eye.skywalking.collector.worker.segment.entity
;
import
com.google.gson.stream.JsonReader
;
import
java.io.FileReader
;
import
java.io.IOException
;
import
java.io.StringReader
;
...
...
@@ -15,7 +13,7 @@ public enum SegmentDeserialize {
INSTANCE
;
public
Segment
deserializeSingle
(
String
singleSegmentJsonStr
)
throws
IOException
{
JsonReader
reader
=
new
JsonReader
(
new
StringReader
(
singleSegmentJsonStr
));
SegmentJsonReader
reader
=
new
Segment
JsonReader
(
new
StringReader
(
singleSegmentJsonStr
));
Segment
segment
=
new
Segment
();
segment
.
deserialize
(
reader
);
return
segment
;
...
...
@@ -28,12 +26,12 @@ public enum SegmentDeserialize {
}
private
void
streamReader
(
List
<
Segment
>
segmentList
,
FileReader
fileReader
)
throws
Exception
{
try
(
JsonReader
reader
=
new
JsonReader
(
fileReader
))
{
try
(
SegmentJsonReader
reader
=
new
Segment
JsonReader
(
fileReader
))
{
readSegmentArray
(
segmentList
,
reader
);
}
}
private
void
readSegmentArray
(
List
<
Segment
>
segmentList
,
JsonReader
reader
)
throws
Exception
{
private
void
readSegmentArray
(
List
<
Segment
>
segmentList
,
Segment
JsonReader
reader
)
throws
Exception
{
reader
.
beginArray
();
while
(
reader
.
hasNext
())
{
Segment
segment
=
new
Segment
();
...
...
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/SegmentJsonReader.java
0 → 100644
浏览文件 @
87eb1e9c
此差异已折叠。
点击以展开。
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/SegmentJsonScope.java
0 → 100644
浏览文件 @
87eb1e9c
package
com.a.eye.skywalking.collector.worker.segment.entity
;
/**
* Copy from {@link com.google.gson.stream.JsonScope}, this class is invisible, {@link SegmentJsonReader} can not use it
* because of the package is different
*
* @author pengys5
*/
public
class
SegmentJsonScope
{
/**
* An array with no elements requires no separators or newlines before
* it is closed.
*/
static
final
int
EMPTY_ARRAY
=
1
;
/**
* A array with at least one value requires a comma and newline before
* the next element.
*/
static
final
int
NONEMPTY_ARRAY
=
2
;
/**
* An object with no name/value pairs requires no separators or newlines
* before it is closed.
*/
static
final
int
EMPTY_OBJECT
=
3
;
/**
* An object whose most recent element is a key. The next element must
* be a value.
*/
static
final
int
DANGLING_NAME
=
4
;
/**
* An object with at least one name/value pair requires a comma and
* newline before the next element.
*/
static
final
int
NONEMPTY_OBJECT
=
5
;
/**
* No object or array has been started.
*/
static
final
int
EMPTY_DOCUMENT
=
6
;
/**
* A document with at an array or object.
*/
static
final
int
NONEMPTY_DOCUMENT
=
7
;
/**
* A document that's been closed and cannot be accessed.
*/
static
final
int
CLOSED
=
8
;
}
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/Span.java
浏览文件 @
87eb1e9c
package
com.a.eye.skywalking.collector.worker.segment.entity
;
import
com.google.gson.stream.JsonReader
;
import
java.io.IOException
;
import
java.util.ArrayList
;
import
java.util.HashMap
;
...
...
@@ -58,7 +56,7 @@ public class Span extends DeserializeObject {
return
logs
;
}
public
Span
deserialize
(
JsonReader
reader
)
throws
IOException
{
public
Span
deserialize
(
Segment
JsonReader
reader
)
throws
IOException
{
StringBuilder
stringBuilder
=
new
StringBuilder
();
stringBuilder
.
append
(
"{"
);
...
...
@@ -87,7 +85,7 @@ public class Span extends DeserializeObject {
JsonBuilder
.
INSTANCE
.
append
(
stringBuilder
,
"et"
,
et
,
first
);
break
;
case
"on"
:
String
on
=
reader
.
nextString
();
String
on
=
reader
.
nextString
()
.
getValue
()
;
this
.
operationName
=
on
;
JsonBuilder
.
INSTANCE
.
append
(
stringBuilder
,
"on"
,
on
,
first
);
break
;
...
...
@@ -97,7 +95,7 @@ public class Span extends DeserializeObject {
while
(
reader
.
hasNext
())
{
String
key
=
reader
.
nextName
();
String
value
=
reader
.
nextString
();
String
value
=
reader
.
nextString
()
.
getOriginValue
()
;
tagsWithStr
.
put
(
key
,
value
);
}
reader
.
endObject
();
...
...
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/segment/entity/TraceSegmentRef.java
浏览文件 @
87eb1e9c
package
com.a.eye.skywalking.collector.worker.segment.entity
;
import
com.google.gson.stream.JsonReader
;
import
java.io.IOException
;
/**
...
...
@@ -32,7 +31,7 @@ public class TraceSegmentRef extends DeserializeObject {
return
peerHost
;
}
public
TraceSegmentRef
deserialize
(
JsonReader
reader
)
throws
IOException
{
public
TraceSegmentRef
deserialize
(
Segment
JsonReader
reader
)
throws
IOException
{
StringBuilder
stringBuilder
=
new
StringBuilder
();
stringBuilder
.
append
(
"{"
);
...
...
@@ -41,7 +40,7 @@ public class TraceSegmentRef extends DeserializeObject {
while
(
reader
.
hasNext
())
{
switch
(
reader
.
nextName
())
{
case
"ts"
:
String
ts
=
reader
.
nextString
();
String
ts
=
reader
.
nextString
()
.
getValue
()
;
this
.
traceSegmentId
=
ts
;
JsonBuilder
.
INSTANCE
.
append
(
stringBuilder
,
"ts"
,
ts
,
first
);
break
;
...
...
@@ -51,12 +50,12 @@ public class TraceSegmentRef extends DeserializeObject {
JsonBuilder
.
INSTANCE
.
append
(
stringBuilder
,
"si"
,
si
,
first
);
break
;
case
"ac"
:
String
ac
=
reader
.
nextString
();
String
ac
=
reader
.
nextString
()
.
getValue
()
;
this
.
applicationCode
=
ac
;
JsonBuilder
.
INSTANCE
.
append
(
stringBuilder
,
"ac"
,
ac
,
first
);
break
;
case
"ph"
:
String
ph
=
reader
.
nextString
();
String
ph
=
reader
.
nextString
()
.
getValue
()
;
this
.
peerHost
=
ph
;
JsonBuilder
.
INSTANCE
.
append
(
stringBuilder
,
"ph"
,
ph
,
first
);
break
;
...
...
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/storage/PersistenceTimer.java
浏览文件 @
87eb1e9c
...
...
@@ -42,7 +42,7 @@ public enum PersistenceTimer {
List
<
AbstractLocalSyncWorker
>
workers
=
PersistenceWorkerListener
.
INSTANCE
.
getWorkers
();
for
(
AbstractLocalSyncWorker
worker
:
workers
)
{
logger
.
info
(
"worker role name: %s"
,
worker
.
getRole
().
roleName
());
logger
.
debug
(
"worker role name: %s"
,
worker
.
getRole
().
roleName
());
try
{
worker
.
allocateJob
(
new
FlushAndSwitch
(),
dataList
);
}
catch
(
Exception
e
)
{
...
...
skywalking-collector/skywalking-collector-worker/src/main/resources/log4j2.xml
浏览文件 @
87eb1e9c
...
...
@@ -16,7 +16,7 @@
</RollingFile>
</Appenders>
<Loggers>
<logger
name=
"com.a.eye.skywalking.collector"
level=
"
debug
"
>
<logger
name=
"com.a.eye.skywalking.collector"
level=
"
INFO
"
>
<AppenderRef
ref=
"RollingFile"
/>
</logger>
<Root
level=
"INFO"
>
...
...
skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/segment/entity/LogDataTestCase.java
浏览文件 @
87eb1e9c
package
com.a.eye.skywalking.collector.worker.segment.entity
;
import
com.google.gson.stream.JsonReader
;
import
java.io.IOException
;
import
java.io.StringReader
;
import
java.util.Map
;
...
...
@@ -16,7 +15,7 @@ public class LogDataTestCase {
public
void
deserialize
()
throws
IOException
{
LogData
logData
=
new
LogData
();
JsonReader
reader
=
new
JsonReader
(
new
StringReader
(
"{\"tm\":1, \"fi\": {\"test1\":\"test1\",\"test2\":\"test2\"}, \"skip\":\"skip\"}"
));
SegmentJsonReader
reader
=
new
Segment
JsonReader
(
new
StringReader
(
"{\"tm\":1, \"fi\": {\"test1\":\"test1\",\"test2\":\"test2\"}, \"skip\":\"skip\"}"
));
logData
.
deserialize
(
reader
);
Assert
.
assertEquals
(
1L
,
logData
.
getTime
());
...
...
skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/segment/entity/TraceSegmentRefTestCase.java
浏览文件 @
87eb1e9c
package
com.a.eye.skywalking.collector.worker.segment.entity
;
import
com.google.gson.stream.JsonReader
;
import
java.io.IOException
;
import
java.io.StringReader
;
import
org.junit.Assert
;
...
...
@@ -14,7 +13,7 @@ public class TraceSegmentRefTestCase {
@Test
public
void
deserialize
()
throws
IOException
{
TraceSegmentRef
traceSegmentRef
=
new
TraceSegmentRef
();
JsonReader
reader
=
new
JsonReader
(
new
StringReader
(
"{\"ts\" :\"ts\",\"si\":0,\"ac\":\"ac\",\"ph\":\"ph\", \"skip\":\"skip\"}"
));
SegmentJsonReader
reader
=
new
Segment
JsonReader
(
new
StringReader
(
"{\"ts\" :\"ts\",\"si\":0,\"ac\":\"ac\",\"ph\":\"ph\", \"skip\":\"skip\"}"
));
traceSegmentRef
.
deserialize
(
reader
);
Assert
.
assertEquals
(
"ts"
,
traceSegmentRef
.
getTraceSegmentId
());
...
...
skywalking-collector/skywalking-collector-worker/src/test/resources/json/segment/post/normal/cache-service.json
浏览文件 @
87eb1e9c
...
...
@@ -120,7 +120,7 @@
"db.type"
:
"sql"
,
"component"
:
"H2"
,
"span.kind"
:
"client"
,
"db.statement"
:
"SELECT id,CACHE_VALUE, CACHE_KEY FROM CACHE_TABLE WHERE CACHE_KEY
\u
003d
?"
,
"db.statement"
:
"SELECT id,CACHE_VALUE, CACHE_KEY FROM CACHE_TABLE WHERE CACHE_KEY ?"
,
"peer.host"
:
"localhost"
},
"tb"
:
{},
...
...
@@ -357,11 +357,20 @@
"ts"
:
{
"span.layer"
:
"rpc"
,
"component"
:
"Motan"
,
"span.kind"
:
"server"
"span.kind"
:
"server"
,
"sql"
:
"select * from table where column=
\"
value
\"
"
},
"tb"
:
{},
"ti"
:
{},
"lo"
:
[]
"lo"
:
[
{
"tm"
:
1490923010332
,
"fi"
:
{
"stack"
:
"com.weibo.api.motan.exception.MotanBizException: error_message: provider call process error, status: 503, error_code: 30001,r
\n\t
at com.weibo.api.motan.rpc.DefaultProvider.invoke(DefaultProvider.java:62)
\n\t
at com.weibo.api.motan.rpc.AbstractProvider.call(AbstractProvider.java:47)
\n\t
at com.weibo.api.motan.filter.opentracing.OpenTracingFilter.process(OpenTracingFilter.java:94)
\n\t
at com.weibo.api.motan.filter.opentracing.OpenTracingFilter.processProviderTrace(OpenTracingFilter.java:148)
\n\t
at com.weibo.api.motan.filter.opentracing.OpenTracingFilter.filter(OpenTracingFilter.java:58)
\n\t
at com.weibo.api.motan.protocol.support.ProtocolFilterDecorator$2.call(ProtocolFilterDecorator.java:150)
\n\t
at com.weibo.api.motan.transport.ProviderMessageRouter.call$original$doBagGo8(ProviderMessageRouter.java:96)
\n\t
at com.weibo.api.motan.transport.ProviderMessageRouter.call$original$doBagGo8$accessor$PEWyOMYz(ProviderMessageRouter.java)
\n\t
at com.weibo.api.motan.transport.ProviderMessageRouter$auxiliary$s7ixnKeK.call(Unknown Source)
\n\t
at com.a.eye.skywalking.api.plugin.interceptor.enhance.ClassInstanceMethodsInterceptor.intercept(ClassInstanceMethodsInterceptor.java:66)
\n\t
at com.weibo.api.motan.transport.ProviderMessageRouter.call(ProviderMessageRouter.java)
\n\t
at com.weibo.api.motan.transport.ProviderProtectedMessageRouter.call(ProviderProtectedMessageRouter.java:79)
\n\t
at com.weibo.api.motan.transport.ProviderMessageRouter.handle(ProviderMessageRouter.java:91)
\n\t
at com.weibo.api.motan.transport.support.DefaultRpcHeartbeatFactory$HeartMessageHandleWrapper.handle(DefaultRpcHeartbeatFactory.java:82)
\n\t
at com.weibo.api.motan.transport.netty.NettyChannelHandler.processRequest(NettyChannelHandler.java:139)
\n\t
at com.weibo.api.motan.transport.netty.NettyChannelHandler.access$000(NettyChannelHandler.java:47)
\n\t
at com.weibo.api.motan.transport.netty.NettyChannelHandler$1.run(NettyChannelHandler.java:116)
\n\t
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
\n\t
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
\n\t
at java.lang.Thread.run(Thread.java:745)
\n
Caused by: java.lang.NullPointerException
\n\t
at com.a.eye.skywalking.test.cache.jedis.JedisServiceManager.findWithException(JedisServiceManager.java:49)
\n\t
at com.a.eye.skywalking.test.cache.CacheServiceImpl.findCacheWithException(CacheServiceImpl.java:46)
\n\t
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
\n\t
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
\n\t
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
\n\t
at java.lang.reflect.Method.invoke(Method.java:498)
\n\t
at com.weibo.api.motan.rpc.DefaultProvider.invoke(DefaultProvider.java:57)
\n\t
... 19 more
\n
com.weibo.api.motan.exception.MotanBizException: error_message: provider call process error, status: 503, error_code: 30001,r
\n\t
at com.weibo.api.motan.rpc.DefaultProvider.invoke(DefaultProvider.java:62)
\n\t
at com.weibo.api.motan.rpc.AbstractProvider.call(AbstractProvider.java:47)
\n\t
at com.weibo.api.motan.filter.opentracing.OpenTracingFilter.process(OpenTracingFilter.java:94)
\n\t
at com.weibo.api.motan.filter.opentracing.OpenTracingFilter.processProviderTrace(OpenTracingFilter.java:148)
\n\t
at com.weibo.api.motan.filter.opentracing.OpenTracingFilter.filter(OpenTracingFilter.java:58)
\n\t
at com.weibo.api.motan.protocol.support.ProtocolFilterDecorator$2.call(ProtocolFilterDecorator.java:150)
\n\t
at com.weibo.api.motan.transport.ProviderMessageRouter.call$original$doBagGo8(ProviderMessageRouter.java:96)
\n\t
at com.weibo.api.motan.transport.ProviderMessageRouter.call$original$doBagGo8$accessor$PEWyOMYz(ProviderMessageRouter.java)
\n\t
at com.weibo.api.motan.transport.ProviderMessageRouter$auxiliary$s7ixnKeK.call(Unknown Source)
\n\t
at com.a.eye.skywalking.api.plugin.interceptor.enhance.ClassInstanceMethodsInterceptor.intercept(ClassInstanceMethodsInterceptor.java:66)
\n\t
at com.weibo.api.motan.transport.ProviderMessageRouter.call(ProviderMessageRouter.java)
\n\t
at com.weibo.api.motan."
,
"special.character"
:
"
\'\"
\\
/"
}
}
]
}
],
"ac"
:
"cache-service"
,
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录