You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oozie.apache.org by rk...@apache.org on 2012/12/07 19:08:48 UTC
svn commit: r1418416 [1/2] - in /oozie/trunk: ./
core/src/main/java/org/apache/oozie/
core/src/main/java/org/apache/oozie/action/hadoop/
core/src/main/java/org/apache/oozie/command/
core/src/main/java/org/apache/oozie/command/bundle/ core/src/main/java...
Author: rkanter
Date: Fri Dec 7 18:08:24 2012
New Revision: 1418416
URL: http://svn.apache.org/viewvc?rev=1418416&view=rev
Log:
OOZIE-1101 Fix log messages that contain {0} or similar (rkanter)
Modified:
oozie/trunk/core/src/main/java/org/apache/oozie/BundleEngine.java
oozie/trunk/core/src/main/java/org/apache/oozie/CoordinatorEngine.java
oozie/trunk/core/src/main/java/org/apache/oozie/DagEngine.java
oozie/trunk/core/src/main/java/org/apache/oozie/ErrorCode.java
oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/ShellActionExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/SqoopActionExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/Command.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/XCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/bundle/BundleStartXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/bundle/BundleSubmitXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionCheckXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionMaterializeCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionStartXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionTimeOutXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordMaterializeTransitionXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordRerunXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSuspendXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ActionXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/CompletedActionXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/DefinitionXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/JobXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/JobsXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ReRunXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ResumeXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SignalXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SubmitHttpXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SubmitXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SuspendXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/WfEndXCommand.java
oozie/trunk/core/src/main/java/org/apache/oozie/coord/CoordUtils.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkDeleteForPurgeJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateDeleteJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertForCoordActionStartJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertForCoordActionStatusJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsCountForJobGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetByLastModifiedTimeJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetStatusPendingJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetCoordinatorsJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetForPurgeJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetNeedStartJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetPausedJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetRunningOrPendingJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetUnpausedJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForCheckJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForExternalIdJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInfoJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInputCheckJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForStartJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForTimeoutJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionRemoveJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateForInputCheckJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateStatusJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsActiveCountJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsGetByLastModifiedTimeJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsPendingFalseCountGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsPendingFalseStatusCountGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsRunningGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionByActionNumberJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionIdsForDateRangeJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionsForDatesJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionsJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionsNotCompletedJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionsRunningJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionsStatusJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionsSubsetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionsSuspendedJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetPendingActionsCountJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetReadyActionsJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetRunningActionsCountJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobUpdateJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetForPurgeJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetPausedJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetPendingJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetUnpausedJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionSubsetGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionUpdateJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionsRunningGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowInfoWithActionsSubsetGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobGetJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobUpdateJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobsGetForPurgeJPAExecutor.java
oozie/trunk/core/src/main/java/org/apache/oozie/service/ActionService.java
oozie/trunk/core/src/main/java/org/apache/oozie/service/AuthorizationService.java
oozie/trunk/core/src/main/java/org/apache/oozie/service/HadoopAccessorService.java
oozie/trunk/core/src/main/java/org/apache/oozie/service/Services.java
oozie/trunk/core/src/main/java/org/apache/oozie/service/StoreService.java
oozie/trunk/core/src/main/java/org/apache/oozie/servlet/ServletUtilities.java
oozie/trunk/core/src/main/java/org/apache/oozie/servlet/V0AdminServlet.java
oozie/trunk/core/src/main/java/org/apache/oozie/servlet/V1JobServlet.java
oozie/trunk/core/src/main/java/org/apache/oozie/store/CoordinatorStore.java
oozie/trunk/core/src/main/java/org/apache/oozie/store/SLAStore.java
oozie/trunk/core/src/main/java/org/apache/oozie/store/WorkflowStore.java
oozie/trunk/core/src/main/java/org/apache/oozie/util/ParamChecker.java
oozie/trunk/core/src/main/java/org/apache/oozie/util/db/SLADbOperations.java
oozie/trunk/core/src/main/java/org/apache/oozie/util/db/SLADbXOperations.java
oozie/trunk/core/src/main/java/org/apache/oozie/workflow/lite/LiteWorkflowApp.java
oozie/trunk/core/src/main/java/org/apache/oozie/workflow/lite/LiteWorkflowAppParser.java
oozie/trunk/core/src/test/java/org/apache/oozie/service/TestCallableQueueService.java
oozie/trunk/core/src/test/java/org/apache/oozie/servlet/MockCoordinatorEngineService.java
oozie/trunk/release-log.txt
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/BundleEngine.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/BundleEngine.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/BundleEngine.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/BundleEngine.java Fri Dec 7 18:08:24 2012
@@ -107,7 +107,7 @@ public class BundleEngine extends BaseEn
*/
@Override
public CoordinatorJob getCoordJob(String jobId) throws BundleEngineException {
- throw new BundleEngineException(new XException(ErrorCode.E0301));
+ throw new BundleEngineException(new XException(ErrorCode.E0301, "cannot get a coordinator job from BundleEngine"));
}
public BundleJobBean getBundleJob(String jobId) throws BundleEngineException {
@@ -124,7 +124,7 @@ public class BundleEngine extends BaseEn
*/
@Override
public CoordinatorJob getCoordJob(String jobId, String filter, int start, int length) throws BundleEngineException {
- throw new BundleEngineException(new XException(ErrorCode.E0301));
+ throw new BundleEngineException(new XException(ErrorCode.E0301, "cannot get a coordinator job from BundleEngine"));
}
/* (non-Javadoc)
@@ -147,7 +147,7 @@ public class BundleEngine extends BaseEn
*/
@Override
public WorkflowJob getJob(String jobId) throws BundleEngineException {
- throw new BundleEngineException(new XException(ErrorCode.E0301));
+ throw new BundleEngineException(new XException(ErrorCode.E0301, "cannot get a workflow job from BundleEngine"));
}
/* (non-Javadoc)
@@ -155,7 +155,7 @@ public class BundleEngine extends BaseEn
*/
@Override
public WorkflowJob getJob(String jobId, int start, int length) throws BundleEngineException {
- throw new BundleEngineException(new XException(ErrorCode.E0301));
+ throw new BundleEngineException(new XException(ErrorCode.E0301, "cannot get a workflow job from BundleEngine"));
}
/* (non-Javadoc)
@@ -185,7 +185,7 @@ public class BundleEngine extends BaseEn
@Override
@Deprecated
public void reRun(String jobId, Configuration conf) throws BundleEngineException {
- throw new BundleEngineException(new XException(ErrorCode.E0301));
+ throw new BundleEngineException(new XException(ErrorCode.E0301, "rerun"));
}
/**
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/CoordinatorEngine.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/CoordinatorEngine.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/CoordinatorEngine.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/CoordinatorEngine.java Fri Dec 7 18:08:24 2012
@@ -193,7 +193,7 @@ public class CoordinatorEngine extends B
@Override
@Deprecated
public void reRun(String jobId, Configuration conf) throws BaseEngineException {
- throw new BaseEngineException(new XException(ErrorCode.E0301));
+ throw new BaseEngineException(new XException(ErrorCode.E0301, "invalid use of rerun"));
}
/**
@@ -235,7 +235,7 @@ public class CoordinatorEngine extends B
@Override
@Deprecated
public void start(String jobId) throws BaseEngineException {
- throw new BaseEngineException(new XException(ErrorCode.E0301));
+ throw new BaseEngineException(new XException(ErrorCode.E0301, "invalid use of start"));
}
/*
@@ -285,14 +285,18 @@ public class CoordinatorEngine extends B
int end;
try {
start = Integer.parseInt(range[0].trim());
+ } catch (NumberFormatException ne) {
+ throw new CommandException(ErrorCode.E0302, "could not parse " + range[0].trim() + "into an integer",
+ ne);
+ }
+ try {
end = Integer.parseInt(range[1].trim());
- if (start > end) {
- throw new CommandException(ErrorCode.E0302, "format is wrong for action's range '" + s
- + "'");
- }
+ } catch (NumberFormatException ne) {
+ throw new CommandException(ErrorCode.E0302, "could not parse " + range[1].trim() + "into an integer",
+ ne);
}
- catch (NumberFormatException ne) {
- throw new CommandException(ErrorCode.E0302, ne);
+ if (start > end) {
+ throw new CommandException(ErrorCode.E0302, "format is wrong for action's range '" + s + "'");
}
for (int i = start; i <= end; i++) {
actions.add(jobId + "@" + i);
@@ -416,7 +420,7 @@ public class CoordinatorEngine extends B
*/
@Override
public WorkflowJob getJob(String jobId) throws BaseEngineException {
- throw new BaseEngineException(new XException(ErrorCode.E0301));
+ throw new BaseEngineException(new XException(ErrorCode.E0301, "cannot get a workflow job from CoordinatorEngine"));
}
/*
@@ -426,7 +430,7 @@ public class CoordinatorEngine extends B
*/
@Override
public WorkflowJob getJob(String jobId, int start, int length) throws BaseEngineException {
- throw new BaseEngineException(new XException(ErrorCode.E0301));
+ throw new BaseEngineException(new XException(ErrorCode.E0301, "cannot get a workflow job from CoordinatorEngine"));
}
private static final Set<String> FILTER_NAMES = new HashSet<String>();
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/DagEngine.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/DagEngine.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/DagEngine.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/DagEngine.java Fri Dec 7 18:08:24 2012
@@ -462,12 +462,12 @@ public class DagEngine extends BaseEngin
@Override
public CoordinatorJob getCoordJob(String jobId) throws BaseEngineException {
- throw new BaseEngineException(new XException(ErrorCode.E0301));
+ throw new BaseEngineException(new XException(ErrorCode.E0301, "cannot get a coordinator job from DagEngine"));
}
@Override
public CoordinatorJob getCoordJob(String jobId, String filter, int start, int length) throws BaseEngineException {
- throw new BaseEngineException(new XException(ErrorCode.E0301));
+ throw new BaseEngineException(new XException(ErrorCode.E0301, "cannot get a coordinator job from DagEngine"));
}
public WorkflowActionBean getWorkflowAction(String actionId) throws BaseEngineException {
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/ErrorCode.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/ErrorCode.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/ErrorCode.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/ErrorCode.java Fri Dec 7 18:08:24 2012
@@ -96,7 +96,7 @@ public enum ErrorCode {
E0600(XLog.OPS, "Could not get connection, {0}"),
E0601(XLog.OPS, "Could not close connection, {0}"),
E0602(XLog.OPS, "Could not commit connection, {0}"),
- E0603(XLog.OPS, "SQL error in operation [{0}], {1}"),
+ E0603(XLog.OPS, "SQL error in operation, {0}"),
E0604(XLog.STD, "Job does not exist [{0}]"),
E0605(XLog.STD, "Action does not exist [{0}]"),
E0606(XLog.STD, "Could not get lock [{0}], timed out [{1}]ms"),
@@ -104,6 +104,7 @@ public enum ErrorCode {
E0608(XLog.OPS, "JDBC setup error [{0}], {1}"),
E0609(XLog.OPS, "Missing [{0}] ORM file [{1}]"),
E0610(XLog.OPS, "Missing JPAService, StoreService cannot run without a JPAService"),
+ E0611(XLog.OPS, "SQL error in operation [{0}], {1}"),
E0700(XLog.STD, "XML error, {0}"),
E0701(XLog.STD, "XML schema error, {0}"),
@@ -177,7 +178,7 @@ public enum ErrorCode {
E1001(XLog.STD, "Could not read the coordinator job definition, {0}"),
E1002(XLog.STD, "Invalid coordinator application URI [{0}], {1}"),
E1003(XLog.STD, "Invalid coordinator application attributes, {0}"),
- E1004(XLog.STD, "Expression language evaluation error [{0}], {1}"),
+ E1004(XLog.STD, "Expression language evaluation error, {0}"),
E1005(XLog.STD, "Could not read the coordinator job configuration read from DB, {0}"),
E1006(XLog.STD, "Invalid coordinator application [{0}], {1}"),
E1007(XLog.STD, "Unable to add record to SLA table. [{0}], {1}"),
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java Fri Dec 7 18:08:24 2012
@@ -195,7 +195,7 @@ public class MapReduceActionExecutor ext
&& (statsJsonString.getBytes().length <= getMaxExternalStatsSize())) {
context.setExecutionStats(statsJsonString);
log.debug(
- "Printing stats for Map-Reduce action as a JSON string : [{0}]" + statsJsonString);
+ "Printing stats for Map-Reduce action as a JSON string : [{0}]", statsJsonString);
}
}
else {
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/ShellActionExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/ShellActionExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/ShellActionExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/ShellActionExecutor.java Fri Dec 7 18:08:24 2012
@@ -116,7 +116,7 @@ public class ShellActionExecutor extends
String[] varValue = pair.split("=");
if (varValue == null || varValue.length <= 1) {
throw new ActionExecutorException(ActionExecutorException.ErrorType.FAILED, "JA010",
- "Wrong ENV format [{0}] in <env-var> , key=value format expected " + pair);
+ "Wrong ENV format [{0}] in <env-var> , key=value format expected ", pair);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/SqoopActionExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/SqoopActionExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/SqoopActionExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/SqoopActionExecutor.java Fri Dec 7 18:08:24 2012
@@ -179,7 +179,7 @@ public class SqoopActionExecutor extends
&& (statsJsonString.getBytes().length <= getMaxExternalStatsSize())) {
context.setExecutionStats(statsJsonString);
log.debug(
- "Printing stats for sqoop action as a JSON string : [{0}]" + statsJsonString);
+ "Printing stats for sqoop action as a JSON string : [{0}]", statsJsonString);
}
} else {
context.setVar(MapReduceActionExecutor.HADOOP_COUNTERS, "");
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/Command.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/Command.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/Command.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/Command.java Fri Dec 7 18:08:24 2012
@@ -237,7 +237,7 @@ public abstract class Command<T, S exten
return result;
}
catch (XException ex) {
- log.error(logMask | XLog.OPS, "XException, {0}", ex);
+ log.error(logMask | XLog.OPS, "XException, {0}", ex.getMessage(), ex);
if (store != null) {
log.info(XLog.STD, "XException - connection logs from store {0}, {1}", store.getConnection(), store
.isClosed());
@@ -266,7 +266,7 @@ public abstract class Command<T, S exten
}
}
catch (Exception ex) {
- log.error(logMask | XLog.OPS, "Exception, {0}", ex);
+ log.error(logMask | XLog.OPS, "Exception, {0}", ex.getMessage(), ex);
exception = true;
if (store != null && store.isActive()) {
try {
@@ -276,10 +276,10 @@ public abstract class Command<T, S exten
log.warn(logMask | XLog.OPS, "openjpa error, {0}, {1}", name, rex.getMessage(), rex);
}
}
- throw new CommandException(ErrorCode.E0607, ex);
+ throw new CommandException(ErrorCode.E0607, name, ex.getMessage(), ex);
}
catch (Error er) {
- log.error(logMask | XLog.OPS, "Error, {0}", er);
+ log.error(logMask | XLog.OPS, "Error, {0}", er.getMessage(), er);
exception = true;
if (store != null && store.isActive()) {
try {
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/XCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/XCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/XCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/XCommand.java Fri Dec 7 18:08:24 2012
@@ -314,7 +314,7 @@ public abstract class XCommand<T> implem
catch (Exception ex) {
LOG.error("Exception, ", ex);
instrumentation.incr(INSTRUMENTATION_GROUP, getName() + ".exceptions", 1);
- throw new CommandException(ErrorCode.E0607, ex);
+ throw new CommandException(ErrorCode.E0607, getName(), ex.getMessage(), ex);
}
finally {
FaultInjection.deactivate("org.apache.oozie.command.SkipCommitFaultInjection");
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/bundle/BundleStartXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/bundle/BundleStartXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/bundle/BundleStartXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/bundle/BundleStartXCommand.java Fri Dec 7 18:08:24 2012
@@ -209,7 +209,7 @@ public class BundleStartXCommand extends
}
}
catch (JDOMException jex) {
- throw new CommandException(ErrorCode.E1301, jex);
+ throw new CommandException(ErrorCode.E1301, jex.getMessage(), jex);
}
// if there is no coordinator for this bundle, failed it.
@@ -275,7 +275,7 @@ public class BundleStartXCommand extends
updateBundleAction();
}
catch (JDOMException jex) {
- throw new CommandException(ErrorCode.E1301, jex);
+ throw new CommandException(ErrorCode.E1301, jex.getMessage(), jex);
}
catch (JPAExecutorException je) {
throw new CommandException(je);
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/bundle/BundleSubmitXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/bundle/BundleSubmitXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/bundle/BundleSubmitXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/bundle/BundleSubmitXCommand.java Fri Dec 7 18:08:24 2012
@@ -253,11 +253,11 @@ public class BundleSubmitXCommand extend
}
catch (IllegalArgumentException iex) {
LOG.warn("IllegalArgumentException: ", iex);
- throw new CommandException(ErrorCode.E1310, iex);
+ throw new CommandException(ErrorCode.E1310, iex.getMessage(), iex);
}
catch (Exception ex) {
LOG.warn("Exception: ", ex);
- throw new CommandException(ErrorCode.E1310, ex);
+ throw new CommandException(ErrorCode.E1310, ex.getMessage(), ex);
}
}
@@ -509,7 +509,7 @@ public class BundleSubmitXCommand extend
}
}
catch (JDOMException jex) {
- throw new CommandException(ErrorCode.E1301, jex);
+ throw new CommandException(ErrorCode.E1301, jex.getMessage(), jex);
}
return null;
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionCheckXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionCheckXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionCheckXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionCheckXCommand.java Fri Dec 7 18:08:24 2012
@@ -176,7 +176,10 @@ public class CoordActionCheckXCommand ex
if (coordAction.getStatus().equals(CoordinatorAction.Status.SUCCEEDED)
|| coordAction.getStatus().equals(CoordinatorAction.Status.FAILED)
|| coordAction.getStatus().equals(CoordinatorAction.Status.KILLED)) {
- throw new PreconditionException(ErrorCode.E1100);
+ throw new PreconditionException(ErrorCode.E1100, "The coord action [" + actionId + "] must not have status "
+ + CoordinatorAction.Status.SUCCEEDED.name() + ", " + CoordinatorAction.Status.FAILED.name()
+ + ", or " + CoordinatorAction.Status.KILLED.name() + " but has status [" + coordAction.getStatus().name()
+ + "]");
}
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionMaterializeCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionMaterializeCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionMaterializeCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionMaterializeCommand.java Fri Dec 7 18:08:24 2012
@@ -120,7 +120,7 @@ public class CoordActionMaterializeComma
}
catch (IOException ioe) {
log.warn("Configuration parse error. read from DB :" + job.getConf(), ioe);
- throw new CommandException(ErrorCode.E1005, ioe);
+ throw new CommandException(ErrorCode.E1005, ioe.getMessage(), ioe);
}
Instrumentation.Cron cron = new Instrumentation.Cron();
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionStartXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionStartXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionStartXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionStartXCommand.java Fri Dec 7 18:08:24 2012
@@ -288,7 +288,8 @@ public class CoordActionStartXCommand ex
@Override
protected void verifyPrecondition() throws PreconditionException {
if (coordAction.getStatus() != CoordinatorAction.Status.SUBMITTED) {
- throw new PreconditionException(ErrorCode.E1100);
+ throw new PreconditionException(ErrorCode.E1100, "The coord action [" + actionId + "] must have status "
+ + CoordinatorAction.Status.SUBMITTED.name() + " but has status [" + coordAction.getStatus().name() + "]");
}
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionTimeOutXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionTimeOutXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionTimeOutXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordActionTimeOutXCommand.java Fri Dec 7 18:08:24 2012
@@ -105,7 +105,8 @@ public class CoordActionTimeOutXCommand
@Override
protected void verifyPrecondition() throws CommandException, PreconditionException {
if (actionBean.getStatus() != CoordinatorAction.Status.WAITING) {
- throw new PreconditionException(ErrorCode.E1100);
+ throw new PreconditionException(ErrorCode.E1100, "The coord action must have status " + CoordinatorAction.Status.WAITING
+ + " but has status [" + actionBean.getStatus() + "]");
}
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordMaterializeTransitionXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordMaterializeTransitionXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordMaterializeTransitionXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordMaterializeTransitionXCommand.java Fri Dec 7 18:08:24 2012
@@ -269,7 +269,7 @@ public class CoordMaterializeTransitionX
}
catch (IOException ioe) {
LOG.warn("Configuration parse error. read from DB :" + coordJob.getConf(), ioe);
- throw new CommandException(ErrorCode.E1005, ioe);
+ throw new CommandException(ErrorCode.E1005, ioe.getMessage(), ioe);
}
String jobXml = coordJob.getJobXml();
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordRerunXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordRerunXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordRerunXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordRerunXCommand.java Fri Dec 7 18:08:24 2012
@@ -185,7 +185,7 @@ public class CoordRerunXCommand extends
}
catch (IOException ioe) {
LOG.warn("Configuration parse error. read from DB :" + coordJob.getConf(), ioe);
- throw new CommandException(ErrorCode.E1005, ioe);
+ throw new CommandException(ErrorCode.E1005, ioe.getMessage(), ioe);
}
String jobXml = coordJob.getJobXml();
Element eJob = XmlUtils.parseXml(jobXml);
@@ -349,11 +349,11 @@ public class CoordRerunXCommand extends
}
catch (JDOMException jex) {
isError = true;
- throw new CommandException(ErrorCode.E0700, jex);
+ throw new CommandException(ErrorCode.E0700, jex.getMessage(), jex);
}
catch (Exception ex) {
isError = true;
- throw new CommandException(ErrorCode.E1018, ex);
+ throw new CommandException(ErrorCode.E1018, ex.getMessage(), ex);
}
finally{
if(isError){
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java Fri Dec 7 18:08:24 2012
@@ -289,12 +289,12 @@ public class CoordSubmitXCommand extends
catch (IllegalArgumentException iex) {
exceptionOccured = true;
LOG.warn("ERROR: ", iex);
- throw new CommandException(ErrorCode.E1003, iex);
+ throw new CommandException(ErrorCode.E1003, iex.getMessage(), iex);
}
catch (Exception ex) {
exceptionOccured = true;
LOG.warn("ERROR: ", ex);
- throw new CommandException(ErrorCode.E0803, ex);
+ throw new CommandException(ErrorCode.E0803, ex.getMessage(), ex);
}
finally {
if (exceptionOccured) {
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSuspendXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSuspendXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSuspendXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSuspendXCommand.java Fri Dec 7 18:08:24 2012
@@ -91,7 +91,7 @@ public class CoordSuspendXCommand extend
}
}
catch (Exception ex) {
- throw new CommandException(ErrorCode.E0603, ex);
+ throw new CommandException(ErrorCode.E0603, ex.getMessage(), ex);
}
LogUtils.setLogInfo(this.coordJob, logInfo);
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ActionXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ActionXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ActionXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ActionXCommand.java Fri Dec 7 18:08:24 2012
@@ -126,7 +126,7 @@ public abstract class ActionXCommand<T>
SuspendXCommand.suspendJob(Services.get().get(JPAService.class), workflow, id, action.getId(), null);
}
catch (Exception e) {
- throw new CommandException(ErrorCode.E0727, e.getMessage());
+ throw new CommandException(ErrorCode.E0727, id, e.getMessage());
}
finally {
// update coordinator action
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/CompletedActionXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/CompletedActionXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/CompletedActionXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/CompletedActionXCommand.java Fri Dec 7 18:08:24 2012
@@ -68,7 +68,7 @@ public class CompletedActionXCommand ext
}
}
catch (Exception ex) {
- throw new CommandException(ErrorCode.E0603, ex);
+ throw new CommandException(ErrorCode.E0603, ex.getMessage(), ex);
}
LogUtils.setLogInfo(this.wfactionBean, logInfo);
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/DefinitionXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/DefinitionXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/DefinitionXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/DefinitionXCommand.java Fri Dec 7 18:08:24 2012
@@ -75,7 +75,7 @@ public class DefinitionXCommand extends
return wfJob.getWorkflowInstance().getApp().getDefinition();
}
else {
- throw new CommandException(ErrorCode.E0604);
+ throw new CommandException(ErrorCode.E0604, "null");
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/JobXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/JobXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/JobXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/JobXCommand.java Fri Dec 7 18:08:24 2012
@@ -71,7 +71,7 @@ public class JobXCommand extends Workflo
throw new CommandException(ex);
}
catch (Exception ex) {
- throw new CommandException(ErrorCode.E0603, ex);
+ throw new CommandException(ErrorCode.E0603, ex.getMessage(), ex);
}
return this.workflow;
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/JobsXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/JobsXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/JobsXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/JobsXCommand.java Fri Dec 7 18:08:24 2012
@@ -69,7 +69,7 @@ public class JobsXCommand extends Workfl
return this.workflows;
}
catch (Exception ex) {
- throw new CommandException(ErrorCode.E0603, ex);
+ throw new CommandException(ErrorCode.E0603, ex.getMessage(), ex);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ReRunXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ReRunXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ReRunXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ReRunXCommand.java Fri Dec 7 18:08:24 2012
@@ -113,6 +113,7 @@ public class ReRunXCommand extends Workf
LogUtils.setLogInfo(wfBean, logInfo);
WorkflowInstance oldWfInstance = this.wfBean.getWorkflowInstance();
WorkflowInstance newWfInstance;
+ String appPath = null;
WorkflowAppService wps = Services.get().get(WorkflowAppService.class);
try {
@@ -121,7 +122,8 @@ public class ReRunXCommand extends Workf
XConfiguration protoActionConf = wps.createProtoActionConf(conf, authToken, true);
WorkflowLib workflowLib = Services.get().get(WorkflowStoreService.class).getWorkflowLibWithNoDB();
- URI uri = new URI(conf.get(OozieClient.APP_PATH));
+ appPath = conf.get(OozieClient.APP_PATH);
+ URI uri = new URI(appPath);
HadoopAccessorService has = Services.get().get(HadoopAccessorService.class);
Configuration fsConf = has.createJobConf(uri.getAuthority());
FileSystem fs = has.createFileSystem(wfBean.getUser(), uri, fsConf);
@@ -161,13 +163,13 @@ public class ReRunXCommand extends Workf
throw new CommandException(ex);
}
catch (IOException ex) {
- throw new CommandException(ErrorCode.E0803, ex);
+ throw new CommandException(ErrorCode.E0803, ex.getMessage(), ex);
}
catch (HadoopAccessorException ex) {
throw new CommandException(ex);
}
catch (URISyntaxException ex) {
- throw new CommandException(ErrorCode.E0711, ex.getMessage(), ex);
+ throw new CommandException(ErrorCode.E0711, appPath, ex.getMessage(), ex);
}
for (int i = 0; i < actions.size(); i++) {
@@ -249,7 +251,7 @@ public class ReRunXCommand extends Workf
}
}
catch (Exception ex) {
- throw new CommandException(ErrorCode.E0603, ex);
+ throw new CommandException(ErrorCode.E0603, ex.getMessage(), ex);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ResumeXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ResumeXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ResumeXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/ResumeXCommand.java Fri Dec 7 18:08:24 2012
@@ -144,10 +144,10 @@ public class ResumeXCommand extends Work
throw new CommandException(e);
}
catch (IOException e) {
- throw new CommandException(ErrorCode.E0902, e);
+ throw new CommandException(ErrorCode.E0902, e.getMessage(), e);
}
catch (URISyntaxException e) {
- throw new CommandException(ErrorCode.E0902, e);
+ throw new CommandException(ErrorCode.E0902, e.getMessage(), e);
}
finally {
// update coordinator action
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SignalXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SignalXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SignalXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SignalXCommand.java Fri Dec 7 18:08:24 2012
@@ -387,7 +387,7 @@ public class SignalXCommand extends Work
}
}
catch (Exception e) {
- throw new CommandException(ErrorCode.E1007, "workflow:Actions " + jobId, e);
+ throw new CommandException(ErrorCode.E1007, "workflow:Actions " + jobId, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SubmitHttpXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SubmitHttpXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SubmitHttpXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SubmitHttpXCommand.java Fri Dec 7 18:08:24 2012
@@ -165,7 +165,7 @@ public abstract class SubmitHttpXCommand
throw new CommandException(ex);
}
catch (Exception ex) {
- throw new CommandException(ErrorCode.E0803, ex);
+ throw new CommandException(ErrorCode.E0803, ex.getMessage(), ex);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SubmitXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SubmitXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SubmitXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SubmitXCommand.java Fri Dec 7 18:08:24 2012
@@ -230,7 +230,7 @@ public class SubmitXCommand extends Work
throw new CommandException(ex);
}
catch (Exception ex) {
- throw new CommandException(ErrorCode.E0803, ex);
+ throw new CommandException(ErrorCode.E0803, ex.getMessage(), ex);
}
}
@@ -266,7 +266,7 @@ public class SubmitXCommand extends Work
}
catch (Exception e) {
e.printStackTrace();
- throw new CommandException(ErrorCode.E1007, "workflow " + id, e);
+ throw new CommandException(ErrorCode.E1007, "workflow " + id, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SuspendXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SuspendXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SuspendXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/SuspendXCommand.java Fri Dec 7 18:08:24 2012
@@ -154,7 +154,7 @@ public class SuspendXCommand extends Wor
}
}
catch (Exception ex) {
- throw new CommandException(ErrorCode.E0603, ex);
+ throw new CommandException(ErrorCode.E0603, ex.getMessage(), ex);
}
LogUtils.setLogInfo(this.wfJobBean, logInfo);
}
@@ -166,7 +166,7 @@ public class SuspendXCommand extends Wor
protected void eagerVerifyPrecondition() throws CommandException, PreconditionException {
super.eagerVerifyPrecondition();
if (this.wfJobBean.getStatus() != WorkflowJob.Status.RUNNING) {
- throw new PreconditionException(ErrorCode.E0727, this.wfJobBean.getStatus());
+ throw new PreconditionException(ErrorCode.E0727, this.wfJobBean.getId(), this.wfJobBean.getStatus());
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/WfEndXCommand.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/WfEndXCommand.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/WfEndXCommand.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/command/wf/WfEndXCommand.java Fri Dec 7 18:08:24 2012
@@ -70,7 +70,7 @@ public class WfEndXCommand extends Workf
}
catch (Exception e) {
LOG.error("Unable to delete WF temp dir of wf id :" + job.getId(), e);
- throw new CommandException(ErrorCode.E0819);
+ throw new CommandException(ErrorCode.E0819, job.getId(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/coord/CoordUtils.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/coord/CoordUtils.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/coord/CoordUtils.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/coord/CoordUtils.java Fri Dec 7 18:08:24 2012
@@ -104,7 +104,7 @@ public class CoordUtils {
}
}
catch (ParseException e) {
- throw new CommandException(ErrorCode.E0302, e);
+ throw new CommandException(ErrorCode.E0302, s.trim(), e);
}
catch (JPAExecutorException e) {
throw new CommandException(e);
@@ -146,17 +146,20 @@ public class CoordUtils {
}
int start;
int end;
+ //Get the starting and ending action numbers
try {
- //Get the starting and ending action numbers
start = Integer.parseInt(range[0].trim());
+ } catch (NumberFormatException ne) {
+ throw new CommandException(ErrorCode.E0302, "could not parse " + range[0].trim() + "into an integer", ne);
+ }
+ try {
end = Integer.parseInt(range[1].trim());
- if (start > end) {
- throw new CommandException(ErrorCode.E0302, "format is wrong for action's range '" + s
- + "', starting action number of the range should be less than ending action number, an example will be 1-4");
- }
+ } catch (NumberFormatException ne) {
+ throw new CommandException(ErrorCode.E0302, "could not parse " + range[1].trim() + "into an integer", ne);
}
- catch (NumberFormatException ne) {
- throw new CommandException(ErrorCode.E0302, ne);
+ if (start > end) {
+ throw new CommandException(ErrorCode.E0302, "format is wrong for action's range '" + s + "', starting action"
+ + "number of the range should be less than ending action number, an example will be 1-4");
}
// Add the actionIds
for (int i = start; i <= end; i++) {
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkDeleteForPurgeJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkDeleteForPurgeJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkDeleteForPurgeJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkDeleteForPurgeJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -106,7 +106,7 @@ public class BulkDeleteForPurgeJPAExecut
}
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
return actionsDeleted;
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -93,7 +93,7 @@ public class BulkJPAExecutor implements
return bulk;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateDeleteJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateDeleteJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateDeleteJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateDeleteJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -127,7 +127,7 @@ public class BulkUpdateDeleteJPAExecutor
throw je;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertForCoordActionStartJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertForCoordActionStartJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertForCoordActionStartJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertForCoordActionStartJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -123,7 +123,7 @@ public class BulkUpdateInsertForCoordAct
return null;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertForCoordActionStatusJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertForCoordActionStatusJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertForCoordActionStatusJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertForCoordActionStatusJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -118,7 +118,7 @@ public class BulkUpdateInsertForCoordAct
return null;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BulkUpdateInsertJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -95,7 +95,7 @@ public class BulkUpdateInsertJPAExecutor
return null;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionGetJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionGetJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionGetJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionGetJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -66,7 +66,7 @@ public class BundleActionGetJPAExecutor
baBeans = q.getResultList();
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
BundleActionBean bean = null;
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsCountForJobGetJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsCountForJobGetJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsCountForJobGetJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsCountForJobGetJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -50,7 +50,7 @@ public class BundleActionsCountForJobGet
return Integer.valueOf(count.intValue());
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetByLastModifiedTimeJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetByLastModifiedTimeJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetByLastModifiedTimeJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetByLastModifiedTimeJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -52,7 +52,7 @@ public class BundleActionsGetByLastModif
baBeans = q.getResultList();
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
return baBeans;
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -64,7 +64,7 @@ public class BundleActionsGetJPAExecutor
baBeans = q.getResultList();
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
return baBeans;
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetStatusPendingJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetStatusPendingJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetStatusPendingJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsGetStatusPendingJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -70,7 +70,7 @@ public class BundleActionsGetStatusPendi
}
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
return baBeans;
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetCoordinatorsJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetCoordinatorsJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetCoordinatorsJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetCoordinatorsJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -68,7 +68,7 @@ public class BundleJobGetCoordinatorsJPA
return coordJobBeans;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -59,7 +59,7 @@ public class BundleJobGetJPAExecutor imp
bdBeans = q.getResultList();
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
BundleJobBean bean = null;
if (bdBeans != null && bdBeans.size() > 0) {
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetForPurgeJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetForPurgeJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetForPurgeJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetForPurgeJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -63,7 +63,7 @@ public class BundleJobsGetForPurgeJPAExe
bundleJobs = jobQ.getResultList();
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
return bundleJobs;
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetNeedStartJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetNeedStartJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetNeedStartJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetNeedStartJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -57,7 +57,7 @@ public class BundleJobsGetNeedStartJPAEx
}
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
return jobList;
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetPausedJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetPausedJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetPausedJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetPausedJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -57,7 +57,7 @@ public class BundleJobsGetPausedJPAExecu
}
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
return jobList;
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetRunningOrPendingJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetRunningOrPendingJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetRunningOrPendingJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetRunningOrPendingJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -63,7 +63,7 @@ public class BundleJobsGetRunningOrPendi
}
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
return jobList;
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetUnpausedJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetUnpausedJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetUnpausedJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetUnpausedJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -57,7 +57,7 @@ public class BundleJobsGetUnpausedJPAExe
}
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
return jobList;
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForCheckJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForCheckJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForCheckJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForCheckJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -62,7 +62,7 @@ public class CoordActionGetForCheckJPAEx
return caBean;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForExternalIdJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForExternalIdJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForExternalIdJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForExternalIdJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -67,7 +67,7 @@ public class CoordActionGetForExternalId
return caBean;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInfoJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInfoJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInfoJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInfoJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -66,7 +66,7 @@ public class CoordActionGetForInfoJPAExe
actionObjects = q.getResultList();
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
if (actionObjects != null && actionObjects.size() > 0) {
@@ -84,7 +84,7 @@ public class CoordActionGetForInfoJPAExe
caBeans = q.getResultList();
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
if (caBeans != null && caBeans.size() > 0) {
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInputCheckJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInputCheckJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInputCheckJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInputCheckJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -62,7 +62,7 @@ public class CoordActionGetForInputCheck
return caBean;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForStartJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForStartJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForStartJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForStartJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -58,7 +58,7 @@ public class CoordActionGetForStartJPAEx
return caBean;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForTimeoutJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForTimeoutJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForTimeoutJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForTimeoutJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -58,7 +58,7 @@ public class CoordActionGetForTimeoutJPA
return caBean;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -59,7 +59,7 @@ public class CoordActionGetJPAExecutor i
caBeans = q.getResultList();
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
CoordinatorActionBean bean = null;
if (caBeans != null && caBeans.size() > 0) {
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionRemoveJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionRemoveJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionRemoveJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionRemoveJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -52,7 +52,7 @@ public class CoordActionRemoveJPAExecuto
try {
actionsDeleted = g.executeUpdate();
} catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
if (actionsDeleted == 0)
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateForInputCheckJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateForInputCheckJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateForInputCheckJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateForInputCheckJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -59,7 +59,7 @@ public class CoordActionUpdateForInputCh
return null;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -53,7 +53,7 @@ public class CoordActionUpdateJPAExecuto
return null;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateStatusJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateStatusJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateStatusJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateStatusJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -58,7 +58,7 @@ public class CoordActionUpdateStatusJPAE
return null;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsActiveCountJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsActiveCountJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsActiveCountJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsActiveCountJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -50,7 +50,7 @@ public class CoordActionsActiveCountJPAE
return Integer.valueOf(count.intValue());
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsGetByLastModifiedTimeJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsGetByLastModifiedTimeJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsGetByLastModifiedTimeJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsGetByLastModifiedTimeJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -59,7 +59,7 @@ public class CoordActionsGetByLastModifi
return coordJobIds;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsPendingFalseCountGetJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsPendingFalseCountGetJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsPendingFalseCountGetJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsPendingFalseCountGetJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -50,7 +50,7 @@ public class CoordActionsPendingFalseCou
return Integer.valueOf(count.intValue());
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsPendingFalseStatusCountGetJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsPendingFalseStatusCountGetJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsPendingFalseStatusCountGetJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsPendingFalseStatusCountGetJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -53,7 +53,7 @@ public class CoordActionsPendingFalseSta
return Integer.valueOf(count.intValue());
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsRunningGetJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsRunningGetJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsRunningGetJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsRunningGetJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -60,7 +60,7 @@ public class CoordActionsRunningGetJPAEx
return coordActionIds;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionByActionNumberJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionByActionNumberJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionByActionNumberJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionByActionNumberJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -58,7 +58,7 @@ public class CoordJobGetActionByActionNu
return actionId;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionIdsForDateRangeJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionIdsForDateRangeJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionIdsForDateRangeJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionIdsForDateRangeJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -61,7 +61,7 @@ public class CoordJobGetActionIdsForDate
return coordActionIds;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}
Modified: oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionsForDatesJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionsForDatesJPAExecutor.java?rev=1418416&r1=1418415&r2=1418416&view=diff
==============================================================================
--- oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionsForDatesJPAExecutor.java (original)
+++ oozie/trunk/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionsForDatesJPAExecutor.java Fri Dec 7 18:08:24 2012
@@ -68,7 +68,7 @@ public class CoordJobGetActionsForDatesJ
return actionList;
}
catch (Exception e) {
- throw new JPAExecutorException(ErrorCode.E0603, e);
+ throw new JPAExecutorException(ErrorCode.E0603, e.getMessage(), e);
}
}