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 6ae06486a53..193b9439512 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. }