diff --git a/core/worker.go b/core/worker.go
index a4db8afd09..be7e1a30ed 100644
--- a/core/worker.go
+++ b/core/worker.go
@@ -450,7 +450,7 @@ func (w *worker) SortPool(tick *time.Ticker) {
 				log.Error("Error reading etx set from db")
 				continue
 			}
-			etxSet.Update(types.Transactions{}, currentHead.NumberU64()) // Prune any expired ETXs
+			etxSet.Update(types.Transactions{}, currentHead.NumberU64()+1) // Prune any expired ETXs
 			// Get transactions from pool
 			pending, err := w.txPool.TxPoolPending(true, etxSet)
 			if err != nil {
@@ -929,7 +929,7 @@ func (w *worker) fillTransactions(interrupt *int32, env *environment, block *typ
 		if etxSet == nil {
 			return
 		}
-		etxSet.Update(types.Transactions{}, block.NumberU64()) // Prune any expired ETXs
+		etxSet.Update(types.Transactions{}, block.NumberU64()+1) // Prune any expired ETXs
 		pending, err := w.txPool.TxPoolPending(true, etxSet)
 		if err != nil {
 			return