Skip to content

Commit

Permalink
Fix spotless on master (#28831)
Browse files Browse the repository at this point in the history
  • Loading branch information
Abacn authored Oct 4, 2023
1 parent c2666e1 commit 6f4e285
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 6f4e285

Please sign in to comment.