Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Ensure traceId is set for write
Browse files Browse the repository at this point in the history
agrawal-siddharth committed Nov 22, 2023
1 parent 39af190 commit ddf5dc7
Showing 2 changed files with 3 additions and 4 deletions.
1 change: 1 addition & 0 deletions CHANGES.md
Original file line number Diff line number Diff line change
@@ -4,6 +4,7 @@

* PR #1117: Make read session caching duration configurable
* PR #1118: Improve read session caching key
* PR #1122: Set traceId on write
* PR #1127: Fix job labeling for mixed case Dataproc job names

## 0.34.0 - 2023-10-31
Original file line number Diff line number Diff line change
@@ -155,10 +155,8 @@ private StreamWriter createStreamWriter(String writeStreamName) {
StreamWriter.Builder streamWriter =
StreamWriter.newBuilder(writeStreamName, writeClient)
.setWriterSchema(this.protoSchema)
.setRetrySettings(this.retrySettings);
if (traceId.isPresent()) {
streamWriter.setTraceId(traceId.get());
}
.setRetrySettings(this.retrySettings)
.setTraceId(traceId.isPresent() ? traceId.get() : "Spark:" + this.writeStreamName);
return streamWriter.build();
} catch (IOException e) {
throw new BigQueryConnectorException("Could not build stream-writer", e);

0 comments on commit ddf5dc7

Please sign in to comment.