Previous commit
Next commit
fix: remove unused attempt param
  • Loading branch information
@olavloite
olavloite committedJun 20, 2020
commit 3ff3ce4ba0e3ad6f0359c179eaabff87939b3613
Original file line numberDiff line numberDiff line change
Expand Up@@ -1086,11 +1086,9 @@ public RetrySettings getPartitionedDmlRetrySettings() {

@Override
public ServerStream<PartialResultSet> executePartitionedDml(
ExecuteSqlRequest request, int attempt, Map<Option, ?> options) {
ExecuteSqlRequest request, Map<Option, ?> options) {
GrpcCallContext context = newCallContext(options, request.getSession());
context =
context.withStreamWaitTimeout(
partitionedDmlRetrySettings.getTotalTimeout().multipliedBy(attempt));
context = context.withStreamWaitTimeout(partitionedDmlRetrySettings.getTotalTimeout());
return partitionedDmlStub.executeSqlCallable().call(request, context);
}

Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -288,7 +288,7 @@ Call read(
RetrySettings getPartitionedDmlRetrySettings();

ServerStream<PartialResultSet> executePartitionedDml(
ExecuteSqlRequest request, int attempt, @Nullable Map<Option, ?> options);
ExecuteSqlRequest request, @Nullable Map<Option, ?> options);

Call executeQuery(
ExecuteSqlRequest request, ResultStreamConsumer consumer, @Nullable Map<Option, ?> options);
Expand Down