HDFS-11305: libhdfs++: Log Datanode information when reading an HDFS block. Contributed by Xiaowei Zhu.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/69d55340 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/69d55340 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/69d55340 Branch: refs/heads/trunk Commit: 69d55340f89a9bf2efc16b00b24c1ebf303e89fe Parents: a30cf6a Author: James <j...@apache.org> Authored: Tue Jan 10 11:25:56 2017 -0500 Committer: James Clampffer <james.clampf...@hp.com> Committed: Thu Mar 22 17:19:47 2018 -0400 ---------------------------------------------------------------------- .../src/main/native/libhdfspp/lib/fs/filehandle.cc | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/69d55340/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/fs/filehandle.cc ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/fs/filehandle.cc b/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/fs/filehandle.cc index 03c517b..1f553a0 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/fs/filehandle.cc +++ b/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/fs/filehandle.cc @@ -225,6 +225,12 @@ void FileHandleImpl::AsyncPreadSome( DatanodeInfoProto &chosen_dn = *it; + std::string dnIpAddr = chosen_dn.id().ipaddr(); + std::string dnHostName = chosen_dn.id().hostname(); + LOG_DEBUG(kFileHandle, << "FileHandleImpl::AsyncPreadSome(" + << FMT_THIS_ADDR << "), ...) Datanode hostname=" << dnHostName << ", IP Address=" << dnIpAddr + << ", file path=\"" << path_ << "\", offset=" << offset); + uint64_t offset_within_block = offset - block->offset(); uint64_t size_within_block = std::min<uint64_t>( block->b().numbytes() - offset_within_block, asio::buffer_size(buffers)); --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
