|
@@ -282,7 +282,7 @@ class Fetcher<K,V> extends Thread {
|
|
LOG.debug("url="+msgToEncode+";encHash="+encHash+";replyHash="+replyHash);
|
|
LOG.debug("url="+msgToEncode+";encHash="+encHash+";replyHash="+replyHash);
|
|
// verify that replyHash is HMac of encHash
|
|
// verify that replyHash is HMac of encHash
|
|
SecureShuffleUtils.verifyReply(replyHash, encHash, jobTokenSecret);
|
|
SecureShuffleUtils.verifyReply(replyHash, encHash, jobTokenSecret);
|
|
- LOG.info("for url="+msgToEncode+" sent hash and receievd reply");
|
|
|
|
|
|
+ LOG.info("for url="+msgToEncode+" sent hash and received reply");
|
|
} catch (IOException ie) {
|
|
} catch (IOException ie) {
|
|
boolean connectExcpt = ie instanceof ConnectException;
|
|
boolean connectExcpt = ie instanceof ConnectException;
|
|
ioErrs.increment(1);
|
|
ioErrs.increment(1);
|