Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
山不在高_有仙则灵
SkyWalking
提交
7419a591
S
SkyWalking
项目概览
山不在高_有仙则灵
/
SkyWalking
与 Fork 源项目一致
Fork自
apache / SkyWalking
通知
12
Star
0
Fork
2
代码
文件
提交
分支
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,发现更多精彩内容 >>
提交
7419a591
编写于
3月 21, 2019
作者:
彭
彭勇升 pengys
提交者:
wu-sheng
3月 20, 2019
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Supplement unexpected exception message. (#2389)
上级
7047c97e
变更
6
隐藏空白更改
内联
并排
Showing
6 changed file
with
11 addition
and
10 deletion
+11
-10
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/IndicatorProcess.java
...ing/oap/server/core/analysis/worker/IndicatorProcess.java
+1
-1
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/RecordProcess.java
...alking/oap/server/core/analysis/worker/RecordProcess.java
+2
-1
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/TopNProcess.java
...ywalking/oap/server/core/analysis/worker/TopNProcess.java
+1
-1
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/worker/InventoryProcess.java
...ing/oap/server/core/register/worker/InventoryProcess.java
+1
-1
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/storage/annotation/StorageEntityAnnotationUtils.java
...core/storage/annotation/StorageEntityAnnotationUtils.java
+4
-4
oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/TopologyQueryEsDAO.java
...torage/plugin/elasticsearch/query/TopologyQueryEsDAO.java
+2
-2
未找到文件。
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/IndicatorProcess.java
浏览文件 @
7419a591
...
...
@@ -49,7 +49,7 @@ public enum IndicatorProcess {
try
{
indicatorDAO
=
storageDAO
.
newIndicatorDao
(
builderClass
.
newInstance
());
}
catch
(
InstantiationException
|
IllegalAccessException
e
)
{
throw
new
UnexpectedException
(
"
"
);
throw
new
UnexpectedException
(
"
Create "
+
builderClass
.
getSimpleName
()
+
" indicator DAO failure."
,
e
);
}
IndicatorPersistentWorker
minutePersistentWorker
=
minutePersistentWorker
(
moduleManager
,
indicatorDAO
,
modelName
);
...
...
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/RecordProcess.java
浏览文件 @
7419a591
...
...
@@ -50,7 +50,8 @@ public enum RecordProcess {
try
{
recordDAO
=
storageDAO
.
newRecordDao
(
builderClass
.
newInstance
());
}
catch
(
InstantiationException
|
IllegalAccessException
e
)
{
throw
new
UnexpectedException
(
""
);
throw
new
UnexpectedException
(
"Create "
+
builderClass
.
getSimpleName
()
+
" record DAO failure."
,
e
);
}
RecordPersistentWorker
persistentWorker
=
new
RecordPersistentWorker
(
WorkerIdGenerator
.
INSTANCES
.
generate
(),
modelName
,
...
...
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/TopNProcess.java
浏览文件 @
7419a591
...
...
@@ -50,7 +50,7 @@ public enum TopNProcess {
try
{
recordDAO
=
storageDAO
.
newRecordDao
(
builderClass
.
newInstance
());
}
catch
(
InstantiationException
|
IllegalAccessException
e
)
{
throw
new
UnexpectedException
(
"
"
);
throw
new
UnexpectedException
(
"
Create "
+
builderClass
.
getSimpleName
()
+
" top n record DAO failure."
,
e
);
}
TopNWorker
persistentWorker
=
new
TopNWorker
(
WorkerIdGenerator
.
INSTANCES
.
generate
(),
modelName
,
moduleManager
,
...
...
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/worker/InventoryProcess.java
浏览文件 @
7419a591
...
...
@@ -49,7 +49,7 @@ public enum InventoryProcess {
try
{
registerDAO
=
storageDAO
.
newRegisterDao
(
builderClass
.
newInstance
());
}
catch
(
InstantiationException
|
IllegalAccessException
e
)
{
throw
new
UnexpectedException
(
"
"
);
throw
new
UnexpectedException
(
"
Create "
+
builderClass
.
getSimpleName
()
+
" register DAO failure."
,
e
);
}
RegisterPersistentWorker
persistentWorker
=
new
RegisterPersistentWorker
(
WorkerIdGenerator
.
INSTANCES
.
generate
(),
modelName
,
moduleManager
,
registerDAO
,
scopeId
);
...
...
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/storage/annotation/StorageEntityAnnotationUtils.java
浏览文件 @
7419a591
...
...
@@ -31,7 +31,7 @@ public class StorageEntityAnnotationUtils {
StorageEntity
annotation
=
(
StorageEntity
)
aClass
.
getAnnotation
(
StorageEntity
.
class
);
return
annotation
.
name
();
}
else
{
throw
new
UnexpectedException
(
"
"
);
throw
new
UnexpectedException
(
"
Fail to get model name from class "
+
aClass
.
getSimpleName
()
);
}
}
...
...
@@ -40,7 +40,7 @@ public class StorageEntityAnnotationUtils {
StorageEntity
annotation
=
(
StorageEntity
)
aClass
.
getAnnotation
(
StorageEntity
.
class
);
return
annotation
.
deleteHistory
();
}
else
{
throw
new
UnexpectedException
(
"
"
);
throw
new
UnexpectedException
(
"
Fail to get delete history tag from class "
+
aClass
.
getSimpleName
()
);
}
}
...
...
@@ -49,7 +49,7 @@ public class StorageEntityAnnotationUtils {
StorageEntity
annotation
=
(
StorageEntity
)
aClass
.
getAnnotation
(
StorageEntity
.
class
);
return
annotation
.
builder
();
}
else
{
throw
new
UnexpectedException
(
"
"
);
throw
new
UnexpectedException
(
"
Fail to get entity builder from class "
+
aClass
.
getSimpleName
()
);
}
}
...
...
@@ -58,7 +58,7 @@ public class StorageEntityAnnotationUtils {
StorageEntity
annotation
=
(
StorageEntity
)
aClass
.
getAnnotation
(
StorageEntity
.
class
);
return
annotation
.
sourceScopeId
();
}
else
{
throw
new
UnexpectedException
(
"
"
);
throw
new
UnexpectedException
(
"
Fail to get source scope from class "
+
aClass
.
getSimpleName
()
);
}
}
}
oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/TopologyQueryEsDAO.java
浏览文件 @
7419a591
...
...
@@ -55,7 +55,7 @@ public class TopologyQueryEsDAO extends EsDAO implements ITopologyQueryDAO {
public
List
<
Call
>
loadSpecifiedServerSideServiceRelations
(
Step
step
,
long
startTB
,
long
endTB
,
List
<
Integer
>
serviceIds
)
throws
IOException
{
if
(
CollectionUtils
.
isEmpty
(
serviceIds
))
{
throw
new
UnexpectedException
(
"Service id is
null
"
);
throw
new
UnexpectedException
(
"Service id is
empty
"
);
}
SearchSourceBuilder
sourceBuilder
=
SearchSourceBuilder
.
searchSource
();
...
...
@@ -70,7 +70,7 @@ public class TopologyQueryEsDAO extends EsDAO implements ITopologyQueryDAO {
public
List
<
Call
>
loadSpecifiedClientSideServiceRelations
(
Step
step
,
long
startTB
,
long
endTB
,
List
<
Integer
>
serviceIds
)
throws
IOException
{
if
(
CollectionUtils
.
isEmpty
(
serviceIds
))
{
throw
new
UnexpectedException
(
"Service id is
null
"
);
throw
new
UnexpectedException
(
"Service id is
empty
"
);
}
SearchSourceBuilder
sourceBuilder
=
SearchSourceBuilder
.
searchSource
();
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录