falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From venkat...@apache.org
Subject [3/5] incubator-falcon git commit: FALCON-820 Fix minor nits with HadoopClientFactory. Contributed by Sowmya Ramesh
Date Sat, 08 Nov 2014 05:32:37 GMT
FALCON-820 Fix minor nits with HadoopClientFactory. Contributed by Sowmya Ramesh


Project: http://git-wip-us.apache.org/repos/asf/incubator-falcon/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-falcon/commit/80b0a16d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-falcon/tree/80b0a16d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-falcon/diff/80b0a16d

Branch: refs/heads/master
Commit: 80b0a16dc5a918f99f74071e7c7ca6a48243cba4
Parents: 112f900
Author: Venkatesh Seetharam <venkatesh@apache.org>
Authored: Fri Nov 7 20:21:59 2014 -0800
Committer: Venkatesh Seetharam <venkatesh@apache.org>
Committed: Fri Nov 7 21:33:26 2014 -0800

----------------------------------------------------------------------
 CHANGES.txt                                                       | 3 +++
 .../java/org/apache/falcon/entity/parser/ClusterEntityParser.java | 2 +-
 2 files changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/80b0a16d/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 7abc820..d2635b7 100755
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -129,6 +129,9 @@ Trunk (Unreleased)
   OPTIMIZATIONS
 
   BUG FIXES
+   FALCON-820 Fix minor nits with HadoopClientFactory
+   (Sowmya Ramesh via Venkatesh Seetharam)
+
    FALCON-815 Rename mapBandwidthKB to mapBandwidth in DistCp
    (Sowmya Ramesh via Venkatesh Seetharam)
 

http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/80b0a16d/common/src/main/java/org/apache/falcon/entity/parser/ClusterEntityParser.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/falcon/entity/parser/ClusterEntityParser.java
b/common/src/main/java/org/apache/falcon/entity/parser/ClusterEntityParser.java
index b801dec..b3496c4 100644
--- a/common/src/main/java/org/apache/falcon/entity/parser/ClusterEntityParser.java
+++ b/common/src/main/java/org/apache/falcon/entity/parser/ClusterEntityParser.java
@@ -271,7 +271,6 @@ public class ClusterEntityParser extends EntityParser<Cluster> {
         throws IOException, ValidationException {
 
         Path locationPath = new Path(location);
-        FileStatus fileStatus = fs.getFileStatus(locationPath);
         if (!fs.exists(locationPath)) {
             throw new ValidationException("Location " + location
                     + " for cluster " + clusterName + " must exist.");
@@ -279,6 +278,7 @@ public class ClusterEntityParser extends EntityParser<Cluster> {
 
         // falcon owns this path on each cluster
         final String loginUser = UserGroupInformation.getLoginUser().getShortUserName();
+        FileStatus fileStatus = fs.getFileStatus(locationPath);
         final String locationOwner = fileStatus.getOwner();
         if (!locationOwner.equals(loginUser)) {
             LOG.error("Location {} has owner {}, should be the process user {}",


Mime
View raw message