Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
DolphinScheduler
提交
ae386dd1
DolphinScheduler
项目概览
apache
/
DolphinScheduler
上一次同步 1 年多
通知
704
Star
9572
Fork
3514
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
DolphinScheduler
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
未验证
提交
ae386dd1
编写于
8月 20, 2021
作者:
W
Wenjun Ruan
提交者:
GitHub
8月 20, 2021
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #6003 from lyxell/fix-unchecked-type-conversions
[Improvement] Fix unchecked type conversions
上级
4b892f7f
db6db88b
变更
4
隐藏空白更改
内联
并排
Showing
4 changed file
with
10 addition
and
12 deletion
+10
-12
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/graph/DAG.java
...in/java/org/apache/dolphinscheduler/common/graph/DAG.java
+5
-7
dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/utils/ResourceProcessDefinitionUtilsTest.java
...heduler/dao/utils/ResourceProcessDefinitionUtilsTest.java
+1
-1
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/dispatch/executor/NettyExecutorManager.java
...server/master/dispatch/executor/NettyExecutorManager.java
+1
-1
dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/master/MasterExecThreadTest.java
.../dolphinscheduler/server/master/MasterExecThreadTest.java
+3
-3
未找到文件。
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/graph/DAG.java
浏览文件 @
ae386dd1
...
...
@@ -432,13 +432,11 @@ public class DAG<Node, NodeInfo, EdgeInfo> {
* @return all neighbor nodes of the node
*/
private
Set
<
Node
>
getNeighborNodes
(
Node
node
,
final
Map
<
Node
,
Map
<
Node
,
EdgeInfo
>>
edges
)
{
final
Map
<
Node
,
EdgeInfo
>
neighborEdges
=
edges
.
get
(
node
);
if
(
neighborEdges
==
null
)
{
return
Collections
.
EMPTY_MAP
.
keySet
();
}
return
neighborEdges
.
keySet
();
final
Map
<
Node
,
EdgeInfo
>
neighborEdges
=
edges
.
get
(
node
);
if
(
neighborEdges
==
null
)
{
return
Collections
.
emptySet
();
}
return
neighborEdges
.
keySet
();
}
...
...
dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/utils/ResourceProcessDefinitionUtilsTest.java
浏览文件 @
ae386dd1
...
...
@@ -31,7 +31,7 @@ public class ResourceProcessDefinitionUtilsTest {
@Test
public
void
getResourceProcessDefinitionMapTest
(){
List
<
Map
<
String
,
Object
>>
mapList
=
new
ArrayList
<>();
Map
<
String
,
Object
>
map
=
new
HashMap
();
Map
<
String
,
Object
>
map
=
new
HashMap
<>
();
map
.
put
(
"code"
,
1L
);
map
.
put
(
"resource_ids"
,
"1,2,3"
);
mapList
.
add
(
map
);
...
...
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/dispatch/executor/NettyExecutorManager.java
浏览文件 @
ae386dd1
...
...
@@ -178,7 +178,7 @@ public class NettyExecutorManager extends AbstractExecutorManager<Boolean>{
* @return nodes
*/
private
Set
<
String
>
getAllNodes
(
ExecutionContext
context
){
Set
<
String
>
nodes
=
Collections
.
EMPTY_SET
;
Set
<
String
>
nodes
=
Collections
.
emptySet
()
;
/**
* executor type
*/
...
...
dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/master/MasterExecThreadTest.java
浏览文件 @
ae386dd1
...
...
@@ -101,8 +101,8 @@ public class MasterExecThreadTest {
cmdParam
.
put
(
CMDPARAM_COMPLEMENT_DATA_END_DATE
,
"2020-01-20 23:00:00"
);
Mockito
.
when
(
processInstance
.
getCommandParam
()).
thenReturn
(
JSONUtils
.
toJsonString
(
cmdParam
));
ProcessDefinition
processDefinition
=
new
ProcessDefinition
();
processDefinition
.
setGlobalParamMap
(
Collections
.
EMPTY_MAP
);
processDefinition
.
setGlobalParamList
(
Collections
.
EMPTY_LIST
);
processDefinition
.
setGlobalParamMap
(
Collections
.
emptyMap
()
);
processDefinition
.
setGlobalParamList
(
Collections
.
emptyList
()
);
Mockito
.
when
(
processInstance
.
getProcessDefinition
()).
thenReturn
(
processDefinition
);
masterExecThread
=
PowerMockito
.
spy
(
new
MasterExecThread
(
processInstance
,
processService
,
null
,
null
,
config
));
...
...
@@ -256,7 +256,7 @@ public class MasterExecThreadTest {
}
private
List
<
Schedule
>
zeroSchedulerList
()
{
return
Collections
.
EMPTY_LIST
;
return
Collections
.
emptyList
()
;
}
private
List
<
Schedule
>
oneSchedulerList
()
{
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录