diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java index 13bb1f26b5..2c556d8fd6 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java @@ -164,7 +164,7 @@ public List listIncomingBatches(List nodeIds, List listIncomingBatches(List filter) { String where = filter != null ? buildBatchWhereFromFilter(filter) : null; Map params = filter != null ? buildBatchParams(filter) : new HashMap(); - String sql = getSql("selectIncomingBatchPrefixSql", where); + String sql = getSql("selectIncomingBatchPrefixSql", where, " order by batch_id desc"); int maxBatches = parameterService.getInt("batch.screen.max.to.select"); if (maxBatches < 1) { maxBatches = Integer.MAX_VALUE; diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java index 4373b9be98..92f71904f7 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java @@ -455,7 +455,7 @@ public List listOutgoingBatches(List nodeIds, List listOutgoingBatches(List filter) { String where = filter != null ? buildBatchWhereFromFilter(filter) : null; Map params = filter != null ? buildBatchParams(filter) : new HashMap(); - String sql = getSql("selectOutgoingBatchPrefixSql", where); + String sql = getSql("selectOutgoingBatchPrefixSql", where, " order by batch_id desc"); int maxBatches = parameterService.getInt("batch.screen.max.to.select"); if (maxBatches < 1) { maxBatches = Integer.MAX_VALUE;