You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ch...@apache.org on 2017/08/30 02:37:36 UTC
hbase git commit: HBASE-18714 The dropBehind and readahead don't be
applied when useHBaseChecksum is enabled
Repository: hbase
Updated Branches:
refs/heads/branch-2 74c517a8b -> ca161288f
HBASE-18714 The dropBehind and readahead don't be applied when useHBaseChecksum is enabled
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/ca161288
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ca161288
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ca161288
Branch: refs/heads/branch-2
Commit: ca161288fb4b03f735af9cfc1685479c64ad5d73
Parents: 74c517a
Author: Chia-Ping Tsai <ch...@gmail.com>
Authored: Tue Aug 29 23:46:15 2017 +0800
Committer: Chia-Ping Tsai <ch...@gmail.com>
Committed: Wed Aug 30 10:31:26 2017 +0800
----------------------------------------------------------------------
.../org/apache/hadoop/hbase/io/FSDataInputStreamWrapper.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/ca161288/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FSDataInputStreamWrapper.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FSDataInputStreamWrapper.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FSDataInputStreamWrapper.java
index 6ae0648..193b943 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FSDataInputStreamWrapper.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FSDataInputStreamWrapper.java
@@ -127,13 +127,13 @@ public class FSDataInputStreamWrapper implements Closeable {
private void setStreamOptions(FSDataInputStream in) {
try {
- this.stream.setDropBehind(dropBehind);
+ in.setDropBehind(dropBehind);
} catch (Exception e) {
// Skipped.
}
if (readahead >= 0) {
try {
- this.stream.setReadahead(readahead);
+ in.setReadahead(readahead);
} catch (Exception e) {
// Skipped.
}