Fix runtime class cast exception in TRA

If we fail to acquire the shard lock, need to retry and wait for the new
cluster state, we were sending the wrong kind of request for the replica
action. This commit fixes this issue.
This commit is contained in:
Jason Tedor 2017-05-11 13:56:43 -04:00
parent e7d352b489
commit 657686cefb
1 changed files with 1 additions and 1 deletions

View File

@ -542,7 +542,7 @@ public abstract class TransportReplicationAction<
new TransportChannelResponseHandler<>(logger, channel, extraMessage,
() -> TransportResponse.Empty.INSTANCE);
transportService.sendRequest(clusterService.localNode(), transportReplicaAction,
new ConcreteShardRequest<>(request, targetAllocationID),
new ConcreteReplicaRequest<>(request, targetAllocationID, globalCheckpoint),
handler);
}