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)