diff --git a/storm-core/src/jvm/storm/trident/topology/MasterBatchCoordinator.java b/storm-core/src/jvm/storm/trident/topology/MasterBatchCoordinator.java
index 78cdd8d983e..32140591a75 100644
--- a/storm-core/src/jvm/storm/trident/topology/MasterBatchCoordinator.java
+++ b/storm-core/src/jvm/storm/trident/topology/MasterBatchCoordinator.java
@@ -199,8 +199,8 @@ private void sync() {
                         _activeTx.put(curr, new TransactionStatus(attempt));
                         _collector.emit(BATCH_STREAM_ID, new Values(attempt), attempt);
                         _throttler.markEvent();
+                        curr = nextTransactionId(curr);
                     }
-                    curr = nextTransactionId(curr);
                 }
             }
         }