diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOMetadata.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOMetadata.java
index 0b5e063c0b5b..1893418dedb3 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOMetadata.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOMetadata.java
@@ -32,8 +32,8 @@ final class BigQueryIOMetadata {
 
   private @Nullable String beamWorkerId;
 
-  private BigQueryIOMetadata(@Nullable String beamJobId, @Nullable String beamJobName,
-      @Nullable String beamWorkerId) {
+  private BigQueryIOMetadata(
+      @Nullable String beamJobId, @Nullable String beamJobName, @Nullable String beamWorkerId) {
     this.beamJobId = beamJobId;
     this.beamJobName = beamJobName;
     this.beamWorkerId = beamWorkerId;
diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java
index 04a665ac9947..1b6cc555511d 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java
@@ -1364,11 +1364,14 @@ public StreamAppendClient getStreamAppendClient(
               .setChannelsPerCpu(2)
               .build();
 
-      String traceId = String.format("Dataflow:%s:%s:%s",
-          bqIOMetadata.getBeamJobName() == null ? options.getJobName()
-              : bqIOMetadata.getBeamJobName(),
-          bqIOMetadata.getBeamJobId() == null ? "" : bqIOMetadata.getBeamJobId(),
-          bqIOMetadata.getBeamWorkerId() == null ? "" : bqIOMetadata.getBeamWorkerId());
+      String traceId =
+          String.format(
+              "Dataflow:%s:%s:%s",
+              bqIOMetadata.getBeamJobName() == null
+                  ? options.getJobName()
+                  : bqIOMetadata.getBeamJobName(),
+              bqIOMetadata.getBeamJobId() == null ? "" : bqIOMetadata.getBeamJobId(),
+              bqIOMetadata.getBeamWorkerId() == null ? "" : bqIOMetadata.getBeamWorkerId());
 
       StreamWriter streamWriter =
           StreamWriter.newBuilder(streamName, newWriteClient)