diff --git a/execution/stagedsync/exec3_parallel.go b/execution/stagedsync/exec3_parallel.go index ffa50cecdd7..78a73aea00c 100644 --- a/execution/stagedsync/exec3_parallel.go +++ b/execution/stagedsync/exec3_parallel.go @@ -4,7 +4,6 @@ import ( "context" "errors" "fmt" - "maps" "os" "runtime" "runtime/pprof" @@ -2988,8 +2987,8 @@ func (be *blockExecutor) nextResult(ctx context.Context, pe *parallelExecutor, r applyResult := txResult{ blockNum: be.number(), blockHash: be.hash(), - traceFroms: map[accounts.Address]struct{}{}, - traceTos: map[accounts.Address]struct{}{}, + traceFroms: result.TraceFroms, + traceTos: result.TraceTos, txNum: task.Version().TxNum, rules: task.Rules(), cumulativeBlobGasUsed: result.cumulativeBlobGasUsed, @@ -3014,8 +3013,6 @@ func (be *blockExecutor) nextResult(ctx context.Context, pe *parallelExecutor, r pe.executedGas.Add(int64(applyResult.blockGasUsed)) } - maps.Copy(applyResult.traceFroms, result.TraceFroms) - maps.Copy(applyResult.traceTos, result.TraceTos) be.cntFinalized++ be.publishTasks.markComplete(tx)