Repository: incubator-hawq Updated Branches: refs/heads/master 9d6159dd1 -> a12012581
HAWQ-1075. Restore default behavior of client side checksum validation. Project: http://git-wip-us.apache.org/repos/asf/incubator-hawq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-hawq/commit/a1201258 Tree: http://git-wip-us.apache.org/repos/asf/incubator-hawq/tree/a1201258 Diff: http://git-wip-us.apache.org/repos/asf/incubator-hawq/diff/a1201258 Branch: refs/heads/master Commit: a12012581649d0028f52c80b4aa722aa6e1f1ce5 Parents: 9d6159d Author: Ed Espino <[email protected]> Authored: Mon Sep 26 15:24:15 2016 -0700 Committer: Ed Espino <[email protected]> Committed: Mon Sep 26 15:26:52 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/hawq/pxf/plugins/hdfs/ChunkRecordReader.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/a1201258/pxf/pxf-hdfs/src/main/java/org/apache/hawq/pxf/plugins/hdfs/ChunkRecordReader.java ---------------------------------------------------------------------- diff --git a/pxf/pxf-hdfs/src/main/java/org/apache/hawq/pxf/plugins/hdfs/ChunkRecordReader.java b/pxf/pxf-hdfs/src/main/java/org/apache/hawq/pxf/plugins/hdfs/ChunkRecordReader.java index 3b10c3e..4e52224 100644 --- a/pxf/pxf-hdfs/src/main/java/org/apache/hawq/pxf/plugins/hdfs/ChunkRecordReader.java +++ b/pxf/pxf-hdfs/src/main/java/org/apache/hawq/pxf/plugins/hdfs/ChunkRecordReader.java @@ -107,9 +107,7 @@ public class ChunkRecordReader implements codec = compressionCodecs.getCodec(file); // open the file and seek to the start of the split - job.setBoolean(DFS_CLIENT_READ_SHORTCIRCUIT_SKIP_CHECKSUM_KEY, true); final FileSystem fs = file.getFileSystem(job); - fs.setVerifyChecksum(false); fileIn = fs.open(file, ChunkReader.DEFAULT_BUFFER_SIZE); fileLength = getInputStream().getFileLength(); if (isCompressedInput()) {
