|
@@ -344,8 +344,6 @@ public class WebHdfsFileSystem extends FileSystem
|
|
*/
|
|
*/
|
|
private synchronized void resetStateToFailOver() {
|
|
private synchronized void resetStateToFailOver() {
|
|
currentNNAddrIndex = (currentNNAddrIndex + 1) % nnAddrs.length;
|
|
currentNNAddrIndex = (currentNNAddrIndex + 1) % nnAddrs.length;
|
|
- delegationToken = null;
|
|
|
|
- tokenAspect.reset();
|
|
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|