|
|
@@ -222,7 +222,7 @@ public class RecoverySourceHandler {
|
|
|
final long numDocsSource = recoverySourceMetadata.getNumDocs();
|
|
|
if (numDocsTarget != numDocsSource) {
|
|
|
throw new IllegalStateException("try to recover " + request.shardId() + " from primary shard with sync id but number " +
|
|
|
- "of docs differ: " + numDocsTarget + " (" + request.sourceNode().getName() + ", primary) vs " + numDocsSource
|
|
|
+ "of docs differ: " + numDocsSource + " (" + request.sourceNode().getName() + ", primary) vs " + numDocsTarget
|
|
|
+ "(" + request.targetNode().getName() + ")");
|
|
|
}
|
|
|
// we shortcut recovery here because we have nothing to copy. but we must still start the engine on the target.
|