From 99303350c93d55bca16e1f0e4dcfdda55de1ff07 Mon Sep 17 00:00:00 2001 From: Alexander Onnikov Date: Mon, 28 Apr 2025 20:57:32 +0700 Subject: [PATCH] UBERF-10383 Ignore premature close errors in datalake (#8743) Signed-off-by: Alexander Onnikov --- services/datalake/pod-datalake/src/handlers/blob.ts | 4 ++++ services/datalake/pod-datalake/src/handlers/image.ts | 4 ++++ 2 files changed, 8 insertions(+) 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 })