Skip to content

Commit ccc0741

Browse files
authored
[BEAM-11648] Fix exception with BigQuery StreamWriter TraceID. (#16616)
1 parent a1f3f86 commit ccc0741

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1197,7 +1197,7 @@ public StreamAppendClient getStreamAppendClient(String streamName, Descriptor de
11971197
StreamWriter streamWriter =
11981198
StreamWriter.newBuilder(streamName)
11991199
.setWriterSchema(protoSchema)
1200-
.setTraceId("Dataflow")
1200+
.setTraceId("Dataflow:" + options.getJobName())
12011201
.build();
12021202
return new StreamAppendClient() {
12031203
private int pins = 0;

0 commit comments

Comments
 (0)