0002107: Initial load extract in background can fail when purge is se…

…t aggressively
JumpMind · Dec 19, 2014 · caf836e · caf836e
1 parent 1a19f7f
commit caf836e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PurgeServiceSqlMap.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PurgeServiceSqlMap.java
@@ -31,7 +31,8 @@ public PurgeServiceSqlMap(IDatabasePlatform platform, Map<String, String> replac
 
         // @formatter:off
 
-        putSql("deleteExtractRequestSql", "delete from $(extract_request) where status=? and last_update_time < ?");
+        putSql("deleteExtractRequestSql", "delete from $(extract_request) where status=? and last_update_time < ? and "
+                + "0 = (select count(1) from sym_outgoing_batch where status != 'OK' and batch_id between start_batch_id and end_batch_id)");
 
         putSql("deleteRegistrationRequestSql", "delete from $(registration_request) where status in (?,?,?) and last_update_time < ?");