Skip to content

Commit dd9bea4

Browse files
committed
review fixes
1 parent bc2d4b4 commit dd9bea4

1 file changed

Lines changed: 2 additions & 6 deletions

File tree

modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2561,11 +2561,9 @@ else if (msg instanceof ZkCommunicationErrorResolveStartMessage) {
25612561
0L,
25622562
evtsData.topVer,
25632563
sndNode.id(),
2564-
null,
2564+
msg,
25652565
evtPath);
25662566

2567-
evtData.resolvedMsg = msg;
2568-
25692567
if (log.isDebugEnabled())
25702568
log.debug("Generated CUSTOM event [evt=" + evtData + ", msg=" + msg + ']');
25712569

@@ -3783,11 +3781,9 @@ private ZkDiscoveryCustomEventData createAckEvent(
37833781
origEvt.eventId(),
37843782
rtState.evtsData.topVer, // Use actual topology version because topology version must be growing.
37853783
locNode.id(),
3786-
null,
3784+
ack,
37873785
null);
37883786

3789-
ackEvtData.resolvedMsg = ack;
3790-
37913787
if (log.isDebugEnabled()) {
37923788
log.debug("Generated CUSTOM event ack [origEvtId=" + origEvt.eventId() +
37933789
", evt=" + ackEvtData +

0 commit comments

Comments
 (0)