hawq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From esp...@apache.org
Subject incubator-hawq git commit: HAWQ-1075. Restore default behavior of client side checksum validation.
Date Mon, 26 Sep 2016 22:27:37 GMT
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 <espino@apache.org>
Authored: Mon Sep 26 15:24:15 2016 -0700
Committer: Ed Espino <espino@apache.org>
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()) {


Mime
View raw message