From 38102420621308f5ba91cdeb6a18a63aa5acf640 Mon Sep 17 00:00:00 2001 From: Junping Du Date: Tue, 5 May 2015 10:18:23 -0700 Subject: [PATCH] YARN-3396. Handle URISyntaxException in ResourceLocalizationService. (Contributed by Brahma Reddy Battula) --- hadoop-yarn-project/CHANGES.txt | 2 ++ .../localizer/ResourceLocalizationService.java | 8 ++++++-- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/hadoop-yarn-project/CHANGES.txt b/hadoop-yarn-project/CHANGES.txt index 97d3208ecd..a6b7f1747f 100644 --- a/hadoop-yarn-project/CHANGES.txt +++ b/hadoop-yarn-project/CHANGES.txt @@ -180,6 +180,8 @@ Release 2.8.0 - UNRELEASED YARN-3363. add localization and container launch time to ContainerMetrics at NM to show these timing information for each active container. (zxu via rkanter) + YARN-3396. Handle URISyntaxException in ResourceLocalizationService. + (Brahma Reddy Battula via junping_du) OPTIMIZATIONS diff --git a/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 b/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 index e9c45f345b..17ea1a9458 100644 --- a/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 +++ b/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 @@ LocalizerHeartbeatResponse processHeartbeat( try { req = new LocalResourceRequest(rsrc); } 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); if (assoc == null) { @@ -1069,7 +1071,9 @@ LocalizerHeartbeatResponse processHeartbeat( LOG.error("Inorrect path for PRIVATE localization." + next.getResource().getFile(), e); } catch (URISyntaxException e) { - //TODO fail? Already translated several times... + LOG.error( + "Got exception in parsing URL of LocalResource:" + + next.getResource(), e); } }