Update error message according to previous change.

Bingqin Zhou · Bingqin Zhou · commit eeb5f39bd3a9 · 2020-03-20T17:22:06.000-07:00
diff --git a/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/write/row/AdaptiveBigQueryWriter.java b/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/write/row/AdaptiveBigQueryWriter.java
@@ -137,7 +137,7 @@ && onlyContainsInvalidSchemaErrors(writeResponse.getInsertErrors()) && autoUpdat
       attemptCount++;
       if (attemptCount >= RETRY_LIMIT) {
         throw new BigQueryConnectException(
-            "Failed to write rows after BQ schema update within "
+            "Failed to write rows after BQ table creation or schema update within "
                 + RETRY_LIMIT + " attempts for: " + tableId.getBaseTableId());
       }
       try {

Original file line number	Diff line number	Diff line change
`@@ -137,7 +137,7 @@ && onlyContainsInvalidSchemaErrors(writeResponse.getInsertErrors()) && autoUpdat`
`137`	`137`	`attemptCount++;`
`138`	`138`	`if (attemptCount >= RETRY_LIMIT) {`
`139`	`139`	`throw new BigQueryConnectException(`
`140`		`- "Failed to write rows after BQ schema update within "`
	`140`	`+ "Failed to write rows after BQ table creation or schema update within "`
`141`	`141`	`+ RETRY_LIMIT + " attempts for: " + tableId.getBaseTableId());`
`142`	`142`	`}`
`143`	`143`	`try {`