HDFS-10301. Prep Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/cddc9689 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/cddc9689 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/cddc9689
Branch: refs/heads/branch-2-HDFS-10301 Commit: cddc968976aded770672e616c38cfd70ddd36361 Parents: 26df6bd Author: Konstantin V Shvachko <s...@apache.org> Authored: Mon Jul 25 17:23:46 2016 -0700 Committer: Konstantin V Shvachko <s...@apache.org> Committed: Mon Jul 25 17:23:46 2016 -0700 ---------------------------------------------------------------------- .../org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/cddc9689/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java index 70004e0..1b61b4b 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java @@ -358,7 +358,7 @@ class BPServiceActor implements Runnable { // Below split threshold, send all reports in a single message. DatanodeCommand cmd = bpNamenode.blockReport( bpRegistration, bpos.getBlockPoolId(), reports, - new BlockReportContext(1, 0, reportId, fullBrLeaseId)); + new BlockReportContext(1, 0, reportId, fullBrLeaseId, true)); numRPCs = 1; numReportsSent = reports.length; if (cmd != null) { @@ -371,7 +371,7 @@ class BPServiceActor implements Runnable { DatanodeCommand cmd = bpNamenode.blockReport( bpRegistration, bpos.getBlockPoolId(), singleReport, new BlockReportContext(reports.length, r, reportId, - fullBrLeaseId)); + fullBrLeaseId, true)); numReportsSent++; numRPCs++; if (cmd != null) { --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
