Repository: oozie Updated Branches: refs/heads/master bf18b66e0 -> 9b1f6b653
Amendment for OOZIE-2127 Project: http://git-wip-us.apache.org/repos/asf/oozie/repo Commit: http://git-wip-us.apache.org/repos/asf/oozie/commit/9b1f6b65 Tree: http://git-wip-us.apache.org/repos/asf/oozie/tree/9b1f6b65 Diff: http://git-wip-us.apache.org/repos/asf/oozie/diff/9b1f6b65 Branch: refs/heads/master Commit: 9b1f6b65312f941964947dfb0942730920aa3210 Parents: bf18b66 Author: egashira <[email protected]> Authored: Fri Feb 6 10:23:10 2015 -0800 Committer: egashira <[email protected]> Committed: Fri Feb 6 10:23:10 2015 -0800 ---------------------------------------------------------------------- .../oozie/executor/jpa/TestWorkflowActionQueryExecutor.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/oozie/blob/9b1f6b65/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowActionQueryExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowActionQueryExecutor.java b/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowActionQueryExecutor.java index 2f3f026..0099f01 100644 --- a/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowActionQueryExecutor.java +++ b/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowActionQueryExecutor.java @@ -19,6 +19,7 @@ package org.apache.oozie.executor.jpa; import java.util.List; +import java.util.Date; import javax.persistence.EntityManager; import javax.persistence.Query; @@ -359,15 +360,16 @@ public class TestWorkflowActionQueryExecutor extends XDataTestCase { //GET_PENDING_ACTIONS sleep(10); long olderThan = 1; + long createdTimeInterval = new Date().getTime() - 1000 * 3600 * 1; retList = WorkflowActionQueryExecutor.getInstance().getList( - WorkflowActionQuery.GET_PENDING_ACTIONS, olderThan); + WorkflowActionQuery.GET_PENDING_ACTIONS, olderThan, createdTimeInterval); assertEquals(2, retList.size()); for(WorkflowActionBean bean : retList){ assertTrue(bean.getId().equals("wrkflow@4") || bean.getId().equals("wrkflow@5")); } olderThan = 10000; retList = WorkflowActionQueryExecutor.getInstance().getList( - WorkflowActionQuery.GET_PENDING_ACTIONS, olderThan); + WorkflowActionQuery.GET_PENDING_ACTIONS, olderThan, createdTimeInterval); assertEquals(0, retList.size()); }
