Repository: oozie Updated Branches: refs/heads/master 0d7b94af4 -> fb1763fd9
OOZIE-1803 Improvement in Purge service (jaydeepvishwakarma via shwethags) - part2 Project: http://git-wip-us.apache.org/repos/asf/oozie/repo Commit: http://git-wip-us.apache.org/repos/asf/oozie/commit/fb1763fd Tree: http://git-wip-us.apache.org/repos/asf/oozie/tree/fb1763fd Diff: http://git-wip-us.apache.org/repos/asf/oozie/diff/fb1763fd Branch: refs/heads/master Commit: fb1763fd9ff917e955970fecee4ed01c77602f12 Parents: 0d7b94a Author: Shwetha GS <[email protected]> Authored: Tue Nov 11 15:07:03 2014 +0530 Committer: Shwetha GS <[email protected]> Committed: Tue Nov 11 15:07:03 2014 +0530 ---------------------------------------------------------------------- ...stWorkflowJobsBasicInfoFromCoordParentIdJPAExecutor.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/oozie/blob/fb1763fd/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsBasicInfoFromCoordParentIdJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsBasicInfoFromCoordParentIdJPAExecutor.java b/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsBasicInfoFromCoordParentIdJPAExecutor.java index e2f8b9a..ba01f29 100644 --- a/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsBasicInfoFromCoordParentIdJPAExecutor.java +++ b/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsBasicInfoFromCoordParentIdJPAExecutor.java @@ -58,9 +58,12 @@ public class TestWorkflowJobsBasicInfoFromCoordParentIdJPAExecutor extends XData HashMap<String,WorkflowJobBean> wflist = new HashMap<String, WorkflowJobBean>(); CoordinatorJobBean coordJobA = addRecordToCoordJobTable(CoordinatorJob.Status.SUCCEEDED, false, false); CoordinatorJobBean coordJobB = addRecordToCoordJobTable(CoordinatorJob.Status.SUCCEEDED, false, false); - WorkflowJobBean wfJobA1 = addRecordToWfJobTable(WorkflowJob.Status.SUCCEEDED, WorkflowInstance.Status.SUCCEEDED); - WorkflowJobBean wfJobA2 = addRecordToWfJobTable(WorkflowJob.Status.SUCCEEDED, WorkflowInstance.Status.SUCCEEDED); - WorkflowJobBean wfJobB = addRecordToWfJobTable(WorkflowJob.Status.SUCCEEDED, WorkflowInstance.Status.SUCCEEDED); + WorkflowJobBean wfJobA1 = addRecordToWfJobTable(WorkflowJob.Status.SUCCEEDED, WorkflowInstance.Status.SUCCEEDED, + coordJobA.getId() + "@1"); + WorkflowJobBean wfJobA2 = addRecordToWfJobTable(WorkflowJob.Status.SUCCEEDED, WorkflowInstance.Status.SUCCEEDED, + coordJobA.getId() + "@2"); + WorkflowJobBean wfJobB = addRecordToWfJobTable(WorkflowJob.Status.SUCCEEDED, WorkflowInstance.Status.SUCCEEDED, + coordJobB.getId() + "@1"); List<WorkflowJobBean> children = new ArrayList<WorkflowJobBean>(); children.addAll(jpaService.execute(new WorkflowJobsBasicInfoFromCoordParentIdJPAExecutor(coordJobA.getId(), 10)));
