From 7cc8ff99f9d44d17fedd16cf5f7a5c2414713fda Mon Sep 17 00:00:00 2001
From: Mahesh Kumar Behera <mbehera@hortonworks.com>
Date: Tue, 25 Sep 2018 15:11:19 +0530
Subject: [PATCH] HIVE-20631 : Hive returns 20011 error code for re-triable
 error

---
 .../apache/hadoop/hive/ql/parse/repl/CopyUtils.java  | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/CopyUtils.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/CopyUtils.java
index 461f5581326c..fe0eaf80260e 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/CopyUtils.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/CopyUtils.java
@@ -212,7 +212,7 @@ private List<Path> getFilesToRetry(FileSystem sourceFs, List<ReplChangeManager.F
   }
 
   // Check if the source file unmodified even after copy to see if we copied the right file
-  private boolean isSourceFileMismatch(FileSystem sourceFs, ReplChangeManager.FileInfo srcFile) {
+  private boolean isSourceFileMismatch(FileSystem sourceFs, ReplChangeManager.FileInfo srcFile) throws IOException {
     // If source is already CM path, the checksum will be always matching
     if (srcFile.isUseSourcePath()) {
       String sourceChecksumString = srcFile.getCheckSum();
@@ -222,9 +222,13 @@ private boolean isSourceFileMismatch(FileSystem sourceFs, ReplChangeManager.File
           verifySourceChecksumString
                   = ReplChangeManager.checksumFor(srcFile.getSourcePath(), sourceFs);
         } catch (IOException e) {
-          // Retry with CM path
-          LOG.debug("Unable to calculate checksum for source file: " + srcFile.getSourcePath());
-          return true;
+          LOG.info("Unable to calculate checksum for source file: " + srcFile.getSourcePath(), e);
+
+          if (!sourceFs.exists(srcFile.getSourcePath())) {
+            // if source file is missing, then return true, so that cm path will be used for copy.
+            return true;
+          }
+          throw e;
         }
         if (!sourceChecksumString.equals(verifySourceChecksumString)) {
           return true;