diff --git a/services/datalake/pod-datalake/src/handlers/blob.ts b/services/datalake/pod-datalake/src/handlers/blob.ts
index ba58354d4d..1733167345 100644
--- a/services/datalake/pod-datalake/src/handlers/blob.ts
+++ b/services/datalake/pod-datalake/src/handlers/blob.ts
@@ -85,6 +85,10 @@ export async function handleBlobGet (
 
   pipeline(blob.body, res, (err) => {
     if (err != null) {
+      // ignore abort errors to avoid flooding the logs
+      if (err.name === 'AbortError' || err.code === 'ERR_STREAM_PREMATURE_CLOSE') {
+        return
+      }
       const error = err instanceof Error ? err.message : String(err)
       ctx.error('error writing response', { workspace, name, error })
       Analytics.handleError(err)
diff --git a/services/datalake/pod-datalake/src/handlers/image.ts b/services/datalake/pod-datalake/src/handlers/image.ts
index 048dcfea30..a5279a5e05 100644
--- a/services/datalake/pod-datalake/src/handlers/image.ts
+++ b/services/datalake/pod-datalake/src/handlers/image.ts
@@ -255,6 +255,10 @@ async function writeFileToResponse (ctx: MeasureContext, path: string, res: Resp
 
   pipeline(stream, res, (err) => {
     if (err != null) {
+      // ignore abort errors to avoid flooding the logs
+      if (err.name === 'AbortError' || err.code === 'ERR_STREAM_PREMATURE_CLOSE') {
+        return
+      }
       Analytics.handleError(err)
       const error = err instanceof Error ? err.message : String(err)
       ctx.error('error writing response', { error })