You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hawq.apache.org by ml...@apache.org on 2016/10/10 14:43:36 UTC
incubator-hawq git commit: HAWQ-1094. Fixed libhdfs3
RemoteBlockReader checksum cannot detect error in some cases
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 <ml...@apache.org>
Authored: Mon Oct 10 22:43:18 2016 +0800
Committer: Ming LI <ml...@apache.org>
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());
}