Skip to content

Commit a95ad18

Browse files
committed
added error logging if query not constructed
1 parent a08bb24 commit a95ad18

File tree

1 file changed

+10
-5
lines changed

1 file changed

+10
-5
lines changed

kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/integration/BaseConnectorIT.java

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -172,11 +172,16 @@ protected Map<String, String> baseConnectorProps(int tasksMax) {
172172
}
173173

174174
protected BigQuery newBigQuery() {
175-
return new GcpClientBuilder.BigQueryBuilder()
176-
.withKey(keyFile())
177-
.withKeySource(GcpClientBuilder.KeySource.valueOf(keySource()))
178-
.withProject(project())
179-
.build();
175+
try {
176+
return new GcpClientBuilder.BigQueryBuilder()
177+
.withKey(keyFile())
178+
.withKeySource(GcpClientBuilder.KeySource.valueOf(keySource()))
179+
.withProject(project())
180+
.build();
181+
} catch (RuntimeException e) {
182+
LoggerFactory.getLogger(BaseConnectorIT.class).error("query error", e);
183+
throw e;
184+
}
180185
}
181186

182187
protected void waitForCommittedRecords(

0 commit comments

Comments
 (0)