diff --git a/core/txpool/locals/tx_tracker.go b/core/txpool/locals/tx_tracker.go index e08384ce71..fe77847cf2 100644 --- a/core/txpool/locals/tx_tracker.go +++ b/core/txpool/locals/tx_tracker.go @@ -185,6 +185,12 @@ func (tracker *TxTracker) loop() { tracker.TrackAll(transactions) return nil }) + + log.Info("Initializing journal writer after loading transactions") + if err := tracker.journal.rotate(make(map[common.Address]types.Transactions)); err != nil { + log.Warn("Failed to initialize journal writer", "err", err) + } + defer tracker.journal.close() } var (