From 616afa5cea8ff7bea58f770aa3dd391da9d58701 Mon Sep 17 00:00:00 2001
From: Alec Huang <alec.huang@snowflake.com>
Date: Mon, 13 May 2024 13:15:00 -0700
Subject: [PATCH] Add error log in telemetry.

---
 .../snowflake/ingest/streaming/internal/FlushService.java    | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/FlushService.java b/src/main/java/net/snowflake/ingest/streaming/internal/FlushService.java
index 7eca40286..69b2c629e 100644
--- a/src/main/java/net/snowflake/ingest/streaming/internal/FlushService.java
+++ b/src/main/java/net/snowflake/ingest/streaming/internal/FlushService.java
@@ -312,6 +312,11 @@ private void createWorkers() {
                     e.getMessage(),
                     getStackTrace(e));
             logger.logError(errorMessage);
+            if (this.owningClient.getTelemetryService() != null) {
+              this.owningClient
+                  .getTelemetryService()
+                  .reportClientFailure(this.getClass().getSimpleName(), errorMessage);
+            }
           }
         },
         0,