You are viewing a plain text version of this content. The canonical link for it is here.
Posted to yarn-commits@hadoop.apache.org by jl...@apache.org on 2014/01/24 20:00:10 UTC
svn commit: r1561113 - in
/hadoop/common/branches/branch-0.23/hadoop-yarn-project: ./
hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/
Author: jlowe
Date: Fri Jan 24 19:00:10 2014
New Revision: 1561113
URL: http://svn.apache.org/r1561113
Log:
YARN-1575. Public localizer crashes with "Localized unkown resource". Contributed by Jason Lowe
Modified:
hadoop/common/branches/branch-0.23/hadoop-yarn-project/CHANGES.txt
hadoop/common/branches/branch-0.23/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ResourceLocalizationService.java
Modified: hadoop/common/branches/branch-0.23/hadoop-yarn-project/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-yarn-project/CHANGES.txt?rev=1561113&r1=1561112&r2=1561113&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-yarn-project/CHANGES.txt (original)
+++ hadoop/common/branches/branch-0.23/hadoop-yarn-project/CHANGES.txt Fri Jan 24 19:00:10 2014
@@ -24,6 +24,9 @@ Release 0.23.11 - UNRELEASED
YARN-1592. CapacityScheduler tries to reserve more than a node's total
memory on branch-0.23 (Omkar Vinit Joshi and Thomas Graves via jlowe)
+ YARN-1575. Public localizer crashes with "Localized unkown resource"
+ (jlowe)
+
Release 0.23.10 - 2013-12-09
INCOMPATIBLE CHANGES
Modified: hadoop/common/branches/branch-0.23/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ResourceLocalizationService.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ResourceLocalizationService.java?rev=1561113&r1=1561112&r2=1561113&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ResourceLocalizationService.java (original)
+++ hadoop/common/branches/branch-0.23/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ResourceLocalizationService.java Fri Jan 24 19:00:10 2014
@@ -635,7 +635,10 @@ public class ResourceLocalizationService
while (!Thread.currentThread().isInterrupted()) {
try {
Future<Path> completed = queue.take();
- LocalizerResourceRequestEvent assoc = pending.remove(completed);
+ LocalizerResourceRequestEvent assoc;
+ synchronized (attempts) {
+ assoc = pending.remove(completed);
+ }
try {
Path local = completed.get();
if (null == assoc) {