Repository: falcon Updated Branches: refs/heads/master ae08745f1 -> a19432953
FALCON-1782 Client returns FalconWebException instead of the expected⦠testing : $ bin/falcon entity -type process -name process1 -properties falcon.scheduler:native -schedule ERROR: Bad Request;default/Entity process1 is already scheduled on configured workflow engine. Author: Praveen Adlakha <[email protected]> Reviewers: Ajay Yadava<[email protected]>, Sandeep Samudrala <[email protected]> Closes #18 from PraveenAdlakha/FALCON-1782 Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/a1943295 Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/a1943295 Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/a1943295 Branch: refs/heads/master Commit: a194329533411849da8ed9addfee77a0249bab31 Parents: ae08745 Author: Praveen Adlakha <[email protected]> Authored: Fri Jan 29 20:11:42 2016 +0530 Committer: Ajay Yadava <[email protected]> Committed: Fri Jan 29 20:11:42 2016 +0530 ---------------------------------------------------------------------- .../apache/falcon/resource/AbstractSchedulableEntityManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/a1943295/prism/src/main/java/org/apache/falcon/resource/AbstractSchedulableEntityManager.java ---------------------------------------------------------------------- diff --git a/prism/src/main/java/org/apache/falcon/resource/AbstractSchedulableEntityManager.java b/prism/src/main/java/org/apache/falcon/resource/AbstractSchedulableEntityManager.java index 8e300aa..864381a 100644 --- a/prism/src/main/java/org/apache/falcon/resource/AbstractSchedulableEntityManager.java +++ b/prism/src/main/java/org/apache/falcon/resource/AbstractSchedulableEntityManager.java @@ -101,9 +101,9 @@ public abstract class AbstractSchedulableEntityManager extends AbstractInstanceM } LOG.info("Memory lock obtained for {} by {}", entityObj.toShortString(), Thread.currentThread().getName()); WorkflowEngineFactory.getWorkflowEngine(entityObj, properties).schedule(entityObj, skipDryRun, properties); - } catch (Exception e) { + } catch (Throwable e) { LOG.error("Entity schedule failed for " + type + ": " + entity, e); - throw FalconWebException.newAPIException("Entity schedule failed for " + type + ": " + entity); + throw FalconWebException.newAPIException(e); } finally { if (entityObj != null) { memoryLocks.releaseLock(entityObj);
