Repository: incubator-hawq Updated Branches: refs/heads/HAWQ-1075 395d790a8 -> 6910a42d6
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/6910a42d Tree: http://git-wip-us.apache.org/repos/asf/incubator-hawq/tree/6910a42d Diff: http://git-wip-us.apache.org/repos/asf/incubator-hawq/diff/6910a42d Branch: refs/heads/HAWQ-1075 Commit: 6910a42d6a9ddaf8f360de2c3cdec56ff6f84de4 Parents: 395d790 Author: Ed Espino <[email protected]> Authored: Mon Sep 26 15:24:15 2016 -0700 Committer: Ed Espino <[email protected]> Committed: Mon Sep 26 15:24:15 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/6910a42d/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()) {
