Skip to content

Commit df361ab

Browse files
author
wangjin18
committed
coordinator group nullpointer
1 parent 07f913b commit df361ab

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/com/jd/joyqueue/service/impl/CoordinatorMonitorServiceImpl.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -124,11 +124,13 @@ public CoordinatorGroupMemberExtension findCoordinatorGroupMember(Subscribe subs
124124
List<CoordinatorGroupMember> members = new ArrayList();
125125
CoordinatorGroupMemberExtension extension = new CoordinatorGroupMemberExtension();
126126
CoordinatorGroup group = findCoordinatorGroup(subscribe);
127-
if (!NullUtil.isEmpty(group) && !NullUtil.isEmpty(group.getMembers())) {
128-
members.addAll(group.getMembers().values());
127+
if (!NullUtil.isEmpty(group)) {
128+
extension.setExtension(group.getExtension());
129+
if(!NullUtil.isEmpty(group.getMembers())) {
130+
members.addAll(group.getMembers().values());
131+
}
129132
}
130133
extension.setMembers(members);
131-
extension.setExtension(group.getExtension());
132134
return extension;
133135
}
134136

0 commit comments

Comments
 (0)