Merge pull request #259 from wepay/fix_log_message

Bingqin Zhou · web-flow · commit 4fb38a8f4b3b · 2020-03-23T16:21:35.000-07:00
Update error message according to previous change.
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 {`