Skip to content

Commit

Permalink
fix(bigquery/storage/managedwriter): correctly copy request (#5122)
Browse files Browse the repository at this point in the history
  • Loading branch information
shollyman committed Nov 12, 2021
1 parent e33350c commit cd43a5c
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions bigquery/storage/managedwriter/managed_stream.go
Expand Up @@ -25,6 +25,7 @@ import (
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1"
"google.golang.org/grpc/codes"
grpcstatus "google.golang.org/grpc/status"
"google.golang.org/protobuf/proto"
"google.golang.org/protobuf/types/descriptorpb"
"google.golang.org/protobuf/types/known/wrapperspb"
)
Expand Down Expand Up @@ -253,15 +254,15 @@ func (ms *ManagedStream) append(pw *pendingWrite, opts ...gax.CallOption) error
}
var req *storagepb.AppendRowsRequest
ms.streamSetup.Do(func() {
reqCopy := *pw.request
reqCopy := proto.Clone(pw.request).(*storagepb.AppendRowsRequest)
reqCopy.WriteStream = ms.streamSettings.streamID
reqCopy.GetProtoRows().WriterSchema = &storagepb.ProtoSchema{
ProtoDescriptor: ms.schemaDescriptor,
}
if ms.streamSettings.TraceID != "" {
reqCopy.TraceId = ms.streamSettings.TraceID
}
req = &reqCopy
req = reqCopy
})

var err error
Expand Down

0 comments on commit cd43a5c

Please sign in to comment.