chore: modify error message on stopped error bq sink (raystack#1)

* chore: modify error message on stopped error bq sink * chore: fix typo --------- Co-authored-by: jesry.pandawa <[email protected]>
goto · Mar 17, 2023 · 4c7d2e4 · 4c7d2e4
1 parent 328d7ff
commit 4c7d2e4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/com/gotocompany/depot/bigquery/client/BigQueryResponseParser.java b/src/main/java/com/gotocompany/depot/bigquery/client/BigQueryResponseParser.java
@@ -42,7 +42,7 @@ public static Map<Long, ErrorInfo> getErrorsFromBQResponse(
             Record record = records.get(errorEntry.getKey().intValue());
             long messageIndex = record.getIndex();
             List<ErrorDescriptor> errors = ErrorParser.parseError(errorEntry.getValue());
-            instrumentation.logError("Error while bigquery insert for message. Record: {}, Error: {}, MetaData: {}",
+            instrumentation.logError("Error while bigquery insert for message. \nRecord: {}, \nError: {}, \nMetaData: {}",
                     record.getColumns(), errors, record.getMetadata());
 
             if (errorMatch(errors, UnknownError.class)) {

diff --git a/src/main/java/com/gotocompany/depot/bigquery/error/StoppedError.java b/src/main/java/com/gotocompany/depot/bigquery/error/StoppedError.java
@@ -22,6 +22,6 @@ public boolean matches() {
 
     @Override
     public String toString() {
-        return "StoppedError: Failed to insert this row because of some (other)error records in batch";
+        return "StoppedError: BigQuery encountered an error on individual rows in the request, none of the rows are inserted. This error can be retried";
     }
 }