[Discovery] fix MembershipAction.sendJoinRequestBlocking should now expect an empty response
The change introduced in #6949 (do not serialize the cluster state) also means master now responds with an empty response rather then a JoinResponse. However, sendJoinRequestBlocking still expected a JoinRequest.
This commit is contained in:
parent
7bf9d7271a
commit
fee22fc0b2
|
@ -92,12 +92,8 @@ public class MembershipAction extends AbstractComponent {
|
||||||
}
|
}
|
||||||
|
|
||||||
public void sendJoinRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, TimeValue timeout) throws ElasticsearchException {
|
public void sendJoinRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, TimeValue timeout) throws ElasticsearchException {
|
||||||
transportService.submitRequest(masterNode, JoinRequestRequestHandler.ACTION, new JoinRequest(node), new FutureTransportResponseHandler<JoinResponse>() {
|
transportService.submitRequest(masterNode, JoinRequestRequestHandler.ACTION, new JoinRequest(node), EmptyTransportResponseHandler.INSTANCE_SAME)
|
||||||
@Override
|
.txGet(timeout.millis(), TimeUnit.MILLISECONDS);
|
||||||
public JoinResponse newInstance() {
|
|
||||||
return new JoinResponse();
|
|
||||||
}
|
|
||||||
}).txGet(timeout.millis(), TimeUnit.MILLISECONDS);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
Loading…
Reference in New Issue