Author: rr
Date: Sat May 22 15:21:19 2010
New Revision: 947308
URL: http://svn.apache.org/viewvc?rev=947308&view=rev
Log:
Load immediate fix
Modified:
ode/branches/APACHE_ODE_1.3.4.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java
ode/branches/APACHE_ODE_1.3.4.X/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/RetriesTest.java
Modified:
ode/branches/APACHE_ODE_1.3.4.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java
URL:
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.3.4.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java?rev=947308&r1=947307&r2=947308&view=diff
==============================================================================
---
ode/branches/APACHE_ODE_1.3.4.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java
(original)
+++
ode/branches/APACHE_ODE_1.3.4.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java
Sat May 22 15:21:19 2010
@@ -116,7 +116,7 @@ public class JdbcDelegate implements Dat
+ "inMem,"
+ "detailsExt"
+ " from ODE_JOB "
- + "where nodeid = ? and scheduled = 0 and ts < ? order by ts";
+ + "where nodeid = ? and ts < ? order by ts";
// public Long instanceId;
// public String mexId;
Modified:
ode/branches/APACHE_ODE_1.3.4.X/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/RetriesTest.java
URL:
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.3.4.X/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/RetriesTest.java?rev=947308&r1=947307&r2=947308&view=diff
==============================================================================
---
ode/branches/APACHE_ODE_1.3.4.X/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/RetriesTest.java
(original)
+++
ode/branches/APACHE_ODE_1.3.4.X/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/RetriesTest.java
Sat May 22 15:21:19 2010
@@ -70,7 +70,7 @@ public class RetriesTest extends TestCas
}
Thread.sleep(10000);
- assertEquals(4, _tried);
+ assertEquals(6, _tried);
}
public void testExecTransaction() throws Exception {