Revert "HADOOP-12469. distcp shout not ignore the ignoreFailures option. Contributed by Mingliang Liu."

This reverts commit fa5a54cac7.
This commit is contained in:
Haohui Mai 2015-10-10 03:24:59 -07:00
parent fa5a54cac7
commit 7e2c971fed
3 changed files with 4 additions and 9 deletions

View File

@ -1277,9 +1277,6 @@ Release 2.8.0 - UNRELEASED
HADOOP-12441. Fixed shell-kill command behaviour to work correctly on some HADOOP-12441. Fixed shell-kill command behaviour to work correctly on some
Linux distributions after HADOOP-12317. (Wangda Tan via vinodkv) Linux distributions after HADOOP-12317. (Wangda Tan via vinodkv)
HADOOP-12469. distcp shout not ignore the ignoreFailures option.
(Mingliang Liu via wheat9)
Release 2.7.2 - UNRELEASED Release 2.7.2 - UNRELEASED
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

View File

@ -288,7 +288,7 @@ private void copyFileWithRetry(String description,
} catch (Exception e) { } catch (Exception e) {
context.setStatus("Copy Failure: " + sourceFileStatus.getPath()); context.setStatus("Copy Failure: " + sourceFileStatus.getPath());
throw new IOException("File copy failed: " + sourceFileStatus.getPath() + throw new IOException("File copy failed: " + sourceFileStatus.getPath() +
" --> " + target, e.getCause()); " --> " + target, e);
} }
incrementCounter(context, Counter.BYTESEXPECTED, sourceFileStatus.getLen()); incrementCounter(context, Counter.BYTESEXPECTED, sourceFileStatus.getLen());
incrementCounter(context, Counter.BYTESCOPIED, bytesCopied); incrementCounter(context, Counter.BYTESCOPIED, bytesCopied);

View File

@ -713,7 +713,7 @@ public Integer run() {
// wrapped twice - once in RetriableCommand and again in CopyMapper // wrapped twice - once in RetriableCommand and again in CopyMapper
// itself. // itself.
if (e.getCause() == null || e.getCause().getCause() == null || if (e.getCause() == null || e.getCause().getCause() == null ||
!(e.getCause() instanceof AccessControlException)) { !(e.getCause().getCause() instanceof AccessControlException)) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
} }
@ -841,10 +841,8 @@ public void testCopyFailOnBlockSizeDifference() {
} }
catch (Exception exception) { catch (Exception exception) {
// Check that the exception suggests the use of -pb/-skipCrc. // Check that the exception suggests the use of -pb/-skipCrc.
Assert.assertTrue("Exception should have suggested the use of -pb.", Assert.assertTrue("Failure exception should have suggested the use of -pb.", exception.getCause().getCause().getMessage().contains("pb"));
exception.getCause().getMessage().contains("pb")); Assert.assertTrue("Failure exception should have suggested the use of -skipCrc.", exception.getCause().getCause().getMessage().contains("skipCrc"));
Assert.assertTrue("Exception should have suggested the use of -skipCrc.",
exception.getCause().getMessage().contains("skipCrc"));
} }
} }