Repository: incubator-hawq Updated Branches: refs/heads/master c7d6a7f52 -> 5f3db03a7
HAWQ-1094. Fixed libhdfs3 RemoteBlockReader checksum cannot detect error in some cases Project: http://git-wip-us.apache.org/repos/asf/incubator-hawq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-hawq/commit/5f3db03a Tree: http://git-wip-us.apache.org/repos/asf/incubator-hawq/tree/5f3db03a Diff: http://git-wip-us.apache.org/repos/asf/incubator-hawq/diff/5f3db03a Branch: refs/heads/master Commit: 5f3db03a7b52c4b14575a09f8af90e8a6be69192 Parents: c7d6a7f Author: Ming LI <[email protected]> Authored: Mon Oct 10 22:43:18 2016 +0800 Committer: Ming LI <[email protected]> Committed: Mon Oct 10 22:43:18 2016 +0800 ---------------------------------------------------------------------- depends/libhdfs3/src/client/RemoteBlockReader.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/5f3db03a/depends/libhdfs3/src/client/RemoteBlockReader.cpp ---------------------------------------------------------------------- diff --git a/depends/libhdfs3/src/client/RemoteBlockReader.cpp b/depends/libhdfs3/src/client/RemoteBlockReader.cpp index f96eb82..54e21b7 100644 --- a/depends/libhdfs3/src/client/RemoteBlockReader.cpp +++ b/depends/libhdfs3/src/client/RemoteBlockReader.cpp @@ -293,7 +293,7 @@ void RemoteBlockReader::verifyChecksum(int chunks) { uint32_t result = checksum->getValue(); uint32_t target = ReadBigEndian32FromArray(pchecksum + (i * checksumSize)); - if (result != target && size == chunkSize) { + if (result != target) { THROW(ChecksumException, "RemoteBlockReader: checksum not match for Block: %s, on Datanode: %s", binfo.toString().c_str(), datanode.formatAddress().c_str()); }
