diff --git a/symmetric/src/main/resources/org/jumpmind/symmetric/service/impl/purge-service-sql.xml b/symmetric/src/main/resources/org/jumpmind/symmetric/service/impl/purge-service-sql.xml index 5dc1bbbae7..52c06d6858 100644 --- a/symmetric/src/main/resources/org/jumpmind/symmetric/service/impl/purge-service-sql.xml +++ b/symmetric/src/main/resources/org/jumpmind/symmetric/service/impl/purge-service-sql.xml @@ -35,8 +35,8 @@ - delete from $[sym.sync.table.prefix]_data d where - d.data_id between :MIN and :MAX and d.data_id not in + delete from $[sym.sync.table.prefix]_data where + data_id between :MIN and :MAX and data_id not in (select e.data_id from $[sym.sync.table.prefix]_data_event e where e.data_id between :MIN and :MAX and e.batch_id in (select o.batch_id from $[sym.sync.table.prefix]_outgoing_batch o where o.status != 'OK' and o.create_time < :TIME))