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 cd9fe431c..7eca40286 100644 --- a/src/main/java/net/snowflake/ingest/streaming/internal/FlushService.java +++ b/src/main/java/net/snowflake/ingest/streaming/internal/FlushService.java @@ -305,7 +305,8 @@ private void createWorkers() { } catch (Exception e) { String errorMessage = String.format( - "Failed to schedule a flush task, client=%s, exception=%s, detail=%s, trace=%s.", + "Failed to schedule a flush task, client=%s, exception=%s, detail=%s," + + " trace=%s.", this.owningClient.getName(), e.getClass().getName(), e.getMessage(),