Skip to content

Commit 0ef9879

Browse files
wicknicksmtagle
authored andcommitted
Log errors encountered when writing batches (#198)
Signed-off-by: Arjun Satish <[email protected]>
1 parent 8af9feb commit 0ef9879

File tree

1 file changed

+1
-0
lines changed
  • kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/write/batch

1 file changed

+1
-0
lines changed

kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/write/batch/TableWriter.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,6 +81,7 @@ public void run() {
8181
currentIndex += currentBatchSize;
8282
successCount++;
8383
} catch (BigQueryException err) {
84+
logger.debug("Could not write batch of size {} to BigQuery.", currentBatch.size(), err);
8485
if (isBatchSizeError(err)) {
8586
failureCount++;
8687
currentBatchSize = getNewBatchSize(currentBatchSize);

0 commit comments

Comments
 (0)