@@ -110,7 +110,6 @@ public class RecoverySourceHandler {
110
110
protected final Logger logger ;
111
111
// Shard that is going to be recovered (the "source")
112
112
private final IndexShard shard ;
113
- private final int shardId ;
114
113
// Request containing source and target node information
115
114
private final StartRecoveryRequest request ;
116
115
private final int chunkSizeInBytes ;
@@ -142,7 +141,6 @@ public RecoverySourceHandler(
142
141
this .threadPool = threadPool ;
143
142
this .recoveryPlannerService = recoveryPlannerService ;
144
143
this .request = request ;
145
- this .shardId = this .request .shardId ().id ();
146
144
this .logger = Loggers .getLogger (getClass (), request .shardId (), "recover to " + request .targetNode ().getName ());
147
145
this .chunkSizeInBytes = fileChunkSizeInBytes ;
148
146
this .maxConcurrentFileChunks = maxConcurrentFileChunks ;
@@ -1433,7 +1431,7 @@ private void handleErrorOnSendFiles(Store store, Exception e, StoreFileMetadata[
1433
1431
cancellableThreads .checkForCancel ();
1434
1432
logger .debug ("checking integrity for file {} after remove corruption exception" , md );
1435
1433
if (store .checkIntegrityNoException (md ) == false ) { // we are corrupted on the primary -- fail!
1436
- logger .warn ("{} Corrupted file detected {} checksum mismatch" , shardId , md );
1434
+ logger .warn ("Corrupted file detected {} checksum mismatch" , md );
1437
1435
if (localException == null ) {
1438
1436
localException = corruptIndexException ;
1439
1437
}
@@ -1449,12 +1447,7 @@ private void handleErrorOnSendFiles(Store store, Exception e, StoreFileMetadata[
1449
1447
);
1450
1448
remoteException .addSuppressed (e );
1451
1449
logger .warn (
1452
- () -> format (
1453
- "%s Remote file corruption on node %s, recovering %s. local checksum OK" ,
1454
- shardId ,
1455
- request .targetNode (),
1456
- mds
1457
- ),
1450
+ () -> format ("Remote file corruption on node %s, recovering %s. local checksum OK" , request .targetNode (), mds ),
1458
1451
corruptIndexException
1459
1452
);
1460
1453
throw remoteException ;
0 commit comments