Add error log in telemetry.

snowflakedb · May 13, 2024 · 616afa5 · 616afa5
1 parent 7de3582
commit 616afa5
Showing 1 changed file with 5 additions and 0 deletions.
diff --git 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,