[beam] branch release-2.36.0 updated: [BEAM-11648] Fix exception with BigQuery StreamWriter TraceID. (#16616)

[em...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

emilyye pushed a commit to branch release-2.36.0
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/release-2.36.0 by this push:
     new ccc0741  [BEAM-11648] Fix exception with BigQuery StreamWriter TraceID. (#16616)
ccc0741 is described below

commit ccc074152af9d4f49ec63239271d7bf16e1f3efb
Author: Chamikara Jayalath <ch...@apache.org>
AuthorDate: Wed Jan 26 10:47:56 2022 -0800

    [BEAM-11648] Fix exception with BigQuery StreamWriter TraceID. (#16616)
---
 .../java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 f607598..0ac1eb9 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
@@ -1197,7 +1197,7 @@ class BigQueryServicesImpl implements BigQueryServices {
       StreamWriter streamWriter =
           StreamWriter.newBuilder(streamName)
               .setWriterSchema(protoSchema)
-              .setTraceId("Dataflow")
+              .setTraceId("Dataflow:" + options.getJobName())
               .build();
       return new StreamAppendClient() {
         private int pins = 0;