Repository: falcon
Updated Branches:
  refs/heads/master 1aac3a502 -> 693e8af52


FALCON-933 misleading error msg on cluster submit failure. Contributed by 
Sowmya Ramesh


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

Branch: refs/heads/master
Commit: 693e8af52e46e673e2a47f0e3b9b44d6dd2e8422
Parents: 1aac3a5
Author: Suhas Vasu <[email protected]>
Authored: Wed Mar 25 14:48:40 2015 +0530
Committer: Suhas Vasu <[email protected]>
Committed: Wed Mar 25 14:48:40 2015 +0530

----------------------------------------------------------------------
 CHANGES.txt                                               |  3 +++
 .../apache/falcon/entity/parser/ClusterEntityParser.java  | 10 +++++-----
 2 files changed, 8 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/falcon/blob/693e8af5/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 027f703..41382d4 100755
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -10,6 +10,9 @@ Trunk (Unreleased)
    FALCON-822 Add reverse look up API (Ajay Yadava via Suhas Vasu)
 
   IMPROVEMENTS
+   FALCON-933 misleading error msg on cluster submit failure
+   (Sowmya Ramesh via Suhas Vasu)
+
    FALCON-910 Better error messages when creating cluster's directories
    (karan kumar via Suhas Vasu)
 

http://git-wip-us.apache.org/repos/asf/falcon/blob/693e8af5/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 2af8c16..4eb3ea8 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
@@ -322,11 +322,11 @@ public class ClusterEntityParser extends 
EntityParser<Cluster> {
             FileStatus fileStatus = fs.getFileStatus(locationPath);
             final String locationOwner = fileStatus.getOwner();
             if (!locationOwner.equals(loginUser)) {
-                LOG.error("Location {} has owner {}, should be the process 
user {}", locationPath, locationOwner,
-                        loginUser);
-                throw new ValidationException(
-                        "Path [" + locationPath + "] has owner [" + 
locationOwner + "], should be the process user "
-                                + loginUser);
+                LOG.error("Owner of the location {} is {} for cluster {}. 
Current user {} is not the owner of the "
+                        + "location.", locationPath, locationOwner, 
clusterName, loginUser);
+                throw new ValidationException("Path [" + locationPath + "] on 
the cluster [" + clusterName + "] has "
+                        + "owner [" + locationOwner + "]. Current user [" + 
loginUser + "] is not the owner of the "
+                        + "path");
             }
             String errorMessage = "Path " + locationPath + " has permissions: 
" + fileStatus.getPermission().toString()
                     + ", should be " + expectedPermission;

Reply via email to