Update MergeQueries.java

confluentinc · Mar 16, 2023 · 18a46dd · 18a46dd
1 parent 3f69fe2
commit 18a46dd
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/MergeQueries.java b/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/MergeQueries.java
@@ -151,7 +151,8 @@ private void mergeFlush(
           if (BigQueryErrorResponses.isCouldNotSerializeAccessError(e)) {
             attempt++;
             if (attempt == 30) {
-              throw new BigQueryConnectException("After retrying running " + attempt + " times, it still failed", e);
+              throw new BigQueryConnectException("Failed to merge rows to destination table `" + destinationTable + "` within " + attempt 
+                                                  + "  attempts due to BQ write serialization error.", e);
             }
             SleepUtils.waitRandomTime(10000, 20000);
           } else {