You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by xg...@apache.org on 2017/01/09 21:30:16 UTC
[21/21] hadoop git commit: HDFS-11301. Double wrapping over
RandomAccessFile in LocalReplicaInPipeline#createStreams. Contributed by
Hanisha Koneru.
HDFS-11301. Double wrapping over RandomAccessFile in LocalReplicaInPipeline#createStreams. Contributed by Hanisha Koneru.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/91bf5044
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/91bf5044
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/91bf5044
Branch: refs/heads/YARN-5734
Commit: 91bf504440967ccdff1cb1cbe7801a5ce2ba88ab
Parents: 287d3d6
Author: Arpit Agarwal <ar...@apache.org>
Authored: Mon Jan 9 10:32:18 2017 -0800
Committer: Arpit Agarwal <ar...@apache.org>
Committed: Mon Jan 9 10:32:18 2017 -0800
----------------------------------------------------------------------
.../hadoop/hdfs/server/datanode/LocalReplicaInPipeline.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/91bf5044/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/LocalReplicaInPipeline.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/LocalReplicaInPipeline.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/LocalReplicaInPipeline.java
index 003f96f..345c329 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/LocalReplicaInPipeline.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/LocalReplicaInPipeline.java
@@ -308,9 +308,7 @@ public class LocalReplicaInPipeline extends LocalReplica
FileOutputStream crcOut = null;
try {
blockOut = fileIoProvider.getFileOutputStream(
- getVolume(),
- fileIoProvider.getRandomAccessFile(getVolume(), blockFile, "rw")
- .getFD());
+ getVolume(), new RandomAccessFile(blockFile, "rw").getFD());
crcOut = fileIoProvider.getFileOutputStream(getVolume(), metaRAF.getFD());
if (!isCreate) {
blockOut.getChannel().position(blockDiskSize);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org