Fixes NPE in ConsistentDeviceMastershipStore
Change-Id: Id07c8d41338a48e58d7e3ea98312691a2011eeef
Showing
1 changed file
with
2 additions
and
1 deletions
| ... | @@ -236,7 +236,8 @@ public class ConsistentDeviceMastershipStore | ... | @@ -236,7 +236,8 @@ public class ConsistentDeviceMastershipStore |
| 236 | 236 | ||
| 237 | String leadershipTopic = createDeviceMastershipTopic(deviceId); | 237 | String leadershipTopic = createDeviceMastershipTopic(deviceId); |
| 238 | Leadership leadership = leadershipService.getLeadership(leadershipTopic); | 238 | Leadership leadership = leadershipService.getLeadership(leadershipTopic); |
| 239 | - return leadership != null ? MastershipTerm.of(leadership.leaderNodeId(), leadership.leader().term()) : null; | 239 | + return leadership != null && leadership.leaderNodeId() != null ? |
| 240 | + MastershipTerm.of(leadership.leaderNodeId(), leadership.leader().term()) : null; | ||
| 240 | } | 241 | } |
| 241 | 242 | ||
| 242 | @Override | 243 | @Override | ... | ... |
-
Please register or login to post a comment