[BEAM-11648] Fix exception with BigQuery StreamWriter TraceID. (#16616)

apache · Jan 26, 2022 · ccc0741 · ccc0741
1 parent a1f3f86
commit ccc0741
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...loud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java b/...loud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java
@@ -1197,7 +1197,7 @@ public StreamAppendClient getStreamAppendClient(String streamName, Descriptor de
       StreamWriter streamWriter =
           StreamWriter.newBuilder(streamName)
               .setWriterSchema(protoSchema)
-              .setTraceId("Dataflow")
+              .setTraceId("Dataflow:" + options.getJobName())
               .build();
       return new StreamAppendClient() {
         private int pins = 0;