We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent deb5424 commit 25b9995Copy full SHA for 25b9995
google-cloud-spanner/src/main/java/com/google/cloud/spanner/BatchClientImpl.java
@@ -315,7 +315,9 @@ private List<Partition> partitionQuery(
315
316
final PartitionQueryRequest request = builder.build();
317
try {
318
- PartitionResponse response = rpc.partitionQuery(request, options);
+ XGoogSpannerRequestId reqId =
319
+ this.session.requestIdCreator.nextRequestId(1 /* channelId */, 0);
320
+ PartitionResponse response = rpc.partitionQuery(request, reqId.withOptions(options));
321
ImmutableList.Builder<Partition> partitions = ImmutableList.builder();
322
for (com.google.spanner.v1.Partition p : response.getPartitionsList()) {
323
Partition partition =
0 commit comments