engine_getBlobsV2 parallel serialization of blob data

siladu · siladu · commit 2585b21f3500 · 2025-11-11T12:12:47.000Z
Mitigates scalability issues since converting blob data toHexString is O(n)

Signed-off-by: Simon Dudley &lt;simon.dudley@consensys.net&gt;
diff --git a/ethereum/api/src/main/java/org/hyperledger/besu/ethereum/api/jsonrpc/internal/methods/engine/EngineGetBlobsV2.java b/ethereum/api/src/main/java/org/hyperledger/besu/ethereum/api/jsonrpc/internal/methods/engine/EngineGetBlobsV2.java
@@ -145,7 +145,7 @@ public JsonRpcResponse syncResponse(final JsonRpcRequestContext requestContext)
     }
 
     final List<BlobAndProofV2> results =
-        validBundles.stream().map(this::createBlobAndProofV2).toList();
+        validBundles.parallelStream().map(this::createBlobAndProofV2).toList();
 
     hitCounter.inc();
     return new JsonRpcSuccessResponse(requestContext.getRequest().getId(), results);

Original file line number	Diff line number	Diff line change
`@@ -145,7 +145,7 @@ public JsonRpcResponse syncResponse(final JsonRpcRequestContext requestContext)`
`145`	`145`	`}`
`146`	`146`
`147`	`147`	`final List<BlobAndProofV2> results =`
`148`		`- validBundles.stream().map(this::createBlobAndProofV2).toList();`
	`148`	`+ validBundles.parallelStream().map(this::createBlobAndProofV2).toList();`
`149`	`149`
`150`	`150`	`hitCounter.inc();`
`151`	`151`	`return new JsonRpcSuccessResponse(requestContext.getRequest().getId(), results);`