This is an automated email from the ASF dual-hosted git repository.

yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 6f4e2852311 Fix spotless on master (#28831)
6f4e2852311 is described below

commit 6f4e2852311db381a622dec3ebf26654c9372806
Author: Yi Hu <[email protected]>
AuthorDate: Wed Oct 4 17:52:46 2023 -0400

    Fix spotless on master (#28831)
---
 .../apache/beam/sdk/io/gcp/bigquery/BigQueryIOMetadata.java |  4 ++--
 .../beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java      | 13 ++++++++-----
 2 files changed, 10 insertions(+), 7 deletions(-)

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 0b5e063c0b5..1893418dedb 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 04a665ac994..1b6cc555511 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 class BigQueryServicesImpl implements 
BigQueryServices {
               .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)

Reply via email to