fix logging (GoogleCloudDataproc#1053)

suryasoma · Aug 29, 2023 · 566d2b4 · 566d2b4
1 parent 365d6fd
commit 566d2b4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...ector-common/src/main/java/com/google/cloud/bigquery/connector/common/BigQueryClient.java b/...ector-common/src/main/java/com/google/cloud/bigquery/connector/common/BigQueryClient.java
@@ -796,17 +796,17 @@ public TableInfo call() {
     }
 
     TableInfo createTableFromQuery() {
-      log.debug("destinationTable is %s", destinationTable);
+      log.debug("destinationTable is {}", destinationTable);
       JobInfo jobInfo =
           JobInfo.of(
               jobConfigurationFactory
                   .createQueryJobConfigurationBuilder(querySql, additionalQueryJobLabels)
                   .setDestinationTable(destinationTable)
                   .build());
 
-      log.debug("running query %s", jobInfo);
+      log.debug("running query {}", jobInfo);
       Job job = waitForJob(bigQueryClient.create(jobInfo));
-      log.debug("job has finished. %s", job);
+      log.debug("job has finished. {}", job);
       if (job.getStatus().getError() != null) {
         throw BigQueryUtil.convertToBigQueryException(job.getStatus().getError());
       }

diff --git a/...r-common/src/main/java/com/google/cloud/bigquery/connector/common/ReadSessionCreator.java b/...r-common/src/main/java/com/google/cloud/bigquery/connector/common/ReadSessionCreator.java
@@ -224,7 +224,7 @@ TableInfo getActualTable(
     if (isInputTableAView(table)) {
       // get it from the view
       String querySql = bigQueryClient.createSql(table.getTableId(), requiredColumns, filters);
-      log.debug("querySql is %s", querySql);
+      log.debug("querySql is {}", querySql);
       return bigQueryClient.materializeViewToTable(
           querySql, table.getTableId(), config.getMaterializationExpirationTimeInMinutes());
     } else {