From 6f4e2852311db381a622dec3ebf26654c9372806 Mon Sep 17 00:00:00 2001 From: Yi Hu Date: Wed, 4 Oct 2023 17:52:46 -0400 Subject: [PATCH] Fix spotless on master (#28831) --- .../sdk/io/gcp/bigquery/BigQueryIOMetadata.java | 4 ++-- .../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 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)