瀏覽代碼

YARN-3396. Handle URISyntaxException in ResourceLocalizationService. (Contributed by Brahma Reddy Battula)

Junping Du 10 年之前
父節點
當前提交
3810242062

+ 2 - 0
hadoop-yarn-project/CHANGES.txt

@@ -180,6 +180,8 @@ Release 2.8.0 - UNRELEASED
     YARN-3363. add localization and container launch time to ContainerMetrics
     YARN-3363. add localization and container launch time to ContainerMetrics
     at NM to show these timing information for each active container.
     at NM to show these timing information for each active container.
     (zxu via rkanter)
     (zxu via rkanter)
+    YARN-3396. Handle URISyntaxException in ResourceLocalizationService. 
+    (Brahma Reddy Battula via junping_du)
 
 
   OPTIMIZATIONS
   OPTIMIZATIONS
 
 

+ 6 - 2
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

@@ -995,7 +995,9 @@ public class ResourceLocalizationService extends CompositeService
         try {
         try {
           req = new LocalResourceRequest(rsrc);
           req = new LocalResourceRequest(rsrc);
         } catch (URISyntaxException e) {
         } catch (URISyntaxException e) {
-          // TODO fail? Already translated several times...
+          LOG.error(
+              "Got exception in parsing URL of LocalResource:"
+                  + rsrc.getResource(), e);
         }
         }
         LocalizerResourceRequestEvent assoc = scheduled.get(req);
         LocalizerResourceRequestEvent assoc = scheduled.get(req);
         if (assoc == null) {
         if (assoc == null) {
@@ -1069,7 +1071,9 @@ public class ResourceLocalizationService extends CompositeService
           LOG.error("Inorrect path for PRIVATE localization."
           LOG.error("Inorrect path for PRIVATE localization."
               + next.getResource().getFile(), e);
               + next.getResource().getFile(), e);
         } catch (URISyntaxException e) {
         } catch (URISyntaxException e) {
-            //TODO fail? Already translated several times...
+          LOG.error(
+              "Got exception in parsing URL of LocalResource:"
+                  + next.getResource(), e);
         }
         }
       }
       }