UBERF-10383 Ignore premature close errors in datalake (#8743) (#9007)

Signed-off-by: Alexander Onnikov <[email protected]>

Author: aonnikov

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)

services/datalake/pod-datalake/src/handlers/image.ts

@@ -239,6 +239,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 })