From 8b517e7ad670aa8ee0b73ce5a572f36ce63eabee Mon Sep 17 00:00:00 2001
From: Steve Loughran <stevel@apache.org>
Date: Wed, 27 Feb 2019 22:56:38 +0000
Subject: [PATCH] HADOOP-16150. checksumFS doesn't wrap concat(): concatenated
 files don't have checksums.

Contributed by Steve Loughran.

Change-Id: I85fc1fc9445ca0b7d325495d3bc55fe9f5e5ce52
---
 .../java/org/apache/hadoop/fs/ChecksumFileSystem.java     | 6 ++++++
 .../localfs/TestLocalFSContractMultipartUploader.java     | 8 ++++++++
 2 files changed, 14 insertions(+)

diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFileSystem.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFileSystem.java
index 59d95cf49a89c..99aa5d22babb4 100644
--- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFileSystem.java
+++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFileSystem.java
@@ -372,6 +372,12 @@ public boolean truncate(Path f, long newLength) throws IOException {
         + "by ChecksumFileSystem");
   }
 
+  @Override
+  public void concat(final Path f, final Path[] psrcs) throws IOException {
+    throw new UnsupportedOperationException("Concat is not supported "
+        + "by ChecksumFileSystem");
+  }
+
   /**
    * Calculated the length of the checksum file in bytes.
    * @param size the length of the data file in bytes
diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/contract/localfs/TestLocalFSContractMultipartUploader.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/contract/localfs/TestLocalFSContractMultipartUploader.java
index 6e27964d8e3d4..f675ddfa0db82 100644
--- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/contract/localfs/TestLocalFSContractMultipartUploader.java
+++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/contract/localfs/TestLocalFSContractMultipartUploader.java
@@ -17,6 +17,8 @@
  */
 package org.apache.hadoop.fs.contract.localfs;
 
+import org.junit.Assume;
+
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.contract.AbstractContractMultipartUploaderTest;
 import org.apache.hadoop.fs.contract.AbstractFSContract;
@@ -27,6 +29,12 @@
 public class TestLocalFSContractMultipartUploader
     extends AbstractContractMultipartUploaderTest {
 
+  @Override
+  public void setup() throws Exception {
+    Assume.assumeTrue("Skipping until HDFS-13934", false);
+    super.setup();
+  }
+
   @Override
   protected AbstractFSContract createContract(Configuration conf) {
     return new LocalFSContract(conf);