You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hawq.apache.org by es...@apache.org on 2016/09/26 22:26:03 UTC
incubator-hawq git commit: HAWQ-1075. Restore default behavior of
client side checksum validation.
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 <es...@apache.org>
Authored: Mon Sep 26 15:24:15 2016 -0700
Committer: Ed Espino <es...@apache.org>
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()) {