Skip to content

Commit 9845a87

Browse files
committed
fix(bigquery): limit HTTP retries to safe operations and enable for createRoutine
1 parent 7aab43a commit 9845a87

1 file changed

Lines changed: 11 additions & 11 deletions

File tree

  • java-bigquery/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery

java-bigquery/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/BigQueryImpl.java

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -397,7 +397,7 @@ public com.google.api.services.bigquery.model.Routine call() throws IOException
397397
}
398398
},
399399
getOptions().getRetrySettings(),
400-
getOptions().getResultRetryAlgorithm(),
400+
getRetryAlgorithmWithHttpRetry(),
401401
getOptions().getClock(),
402402
EMPTY_RETRY_CONFIG,
403403
getOptions().isOpenTelemetryTracingEnabled(),
@@ -711,7 +711,7 @@ public Boolean call() throws IOException {
711711
}
712712
},
713713
getOptions().getRetrySettings(),
714-
getRetryAlgorithmWithHttpRetry(),
714+
getOptions().getResultRetryAlgorithm(),
715715
getOptions().getClock(),
716716
EMPTY_RETRY_CONFIG,
717717
getOptions().isOpenTelemetryTracingEnabled(),
@@ -762,7 +762,7 @@ public Boolean call() throws IOException {
762762
}
763763
},
764764
getOptions().getRetrySettings(),
765-
getRetryAlgorithmWithHttpRetry(),
765+
getOptions().getResultRetryAlgorithm(),
766766
getOptions().getClock(),
767767
EMPTY_RETRY_CONFIG,
768768
getOptions().isOpenTelemetryTracingEnabled(),
@@ -808,7 +808,7 @@ public Boolean call() throws IOException {
808808
}
809809
},
810810
getOptions().getRetrySettings(),
811-
getRetryAlgorithmWithHttpRetry(),
811+
getOptions().getResultRetryAlgorithm(),
812812
getOptions().getClock(),
813813
EMPTY_RETRY_CONFIG,
814814
getOptions().isOpenTelemetryTracingEnabled(),
@@ -854,7 +854,7 @@ public Boolean call() throws IOException {
854854
}
855855
},
856856
getOptions().getRetrySettings(),
857-
getRetryAlgorithmWithHttpRetry(),
857+
getOptions().getResultRetryAlgorithm(),
858858
getOptions().getClock(),
859859
EMPTY_RETRY_CONFIG,
860860
getOptions().isOpenTelemetryTracingEnabled(),
@@ -898,7 +898,7 @@ public Boolean call() throws IOException {
898898
}
899899
},
900900
getOptions().getRetrySettings(),
901-
getRetryAlgorithmWithHttpRetry(),
901+
getOptions().getResultRetryAlgorithm(),
902902
getOptions().getClock(),
903903
EMPTY_RETRY_CONFIG,
904904
getOptions().isOpenTelemetryTracingEnabled(),
@@ -939,7 +939,7 @@ public com.google.api.services.bigquery.model.Dataset call() throws IOException
939939
}
940940
},
941941
getOptions().getRetrySettings(),
942-
getRetryAlgorithmWithHttpRetry(),
942+
getOptions().getResultRetryAlgorithm(),
943943
getOptions().getClock(),
944944
EMPTY_RETRY_CONFIG,
945945
getOptions().isOpenTelemetryTracingEnabled(),
@@ -986,7 +986,7 @@ public com.google.api.services.bigquery.model.Table call() throws IOException {
986986
}
987987
},
988988
getOptions().getRetrySettings(),
989-
getRetryAlgorithmWithHttpRetry(),
989+
getOptions().getResultRetryAlgorithm(),
990990
getOptions().getClock(),
991991
EMPTY_RETRY_CONFIG,
992992
getOptions().isOpenTelemetryTracingEnabled(),
@@ -1032,7 +1032,7 @@ public com.google.api.services.bigquery.model.Model call() throws IOException {
10321032
}
10331033
},
10341034
getOptions().getRetrySettings(),
1035-
getRetryAlgorithmWithHttpRetry(),
1035+
getOptions().getResultRetryAlgorithm(),
10361036
getOptions().getClock(),
10371037
EMPTY_RETRY_CONFIG,
10381038
getOptions().isOpenTelemetryTracingEnabled(),
@@ -1078,7 +1078,7 @@ public com.google.api.services.bigquery.model.Routine call() throws IOException
10781078
}
10791079
},
10801080
getOptions().getRetrySettings(),
1081-
getRetryAlgorithmWithHttpRetry(),
1081+
getOptions().getResultRetryAlgorithm(),
10821082
getOptions().getClock(),
10831083
EMPTY_RETRY_CONFIG,
10841084
getOptions().isOpenTelemetryTracingEnabled(),
@@ -1632,7 +1632,7 @@ public TableDataInsertAllResponse call() throws Exception {
16321632
}
16331633
},
16341634
getOptions().getRetrySettings(),
1635-
getRetryAlgorithmWithHttpRetry(),
1635+
getOptions().getResultRetryAlgorithm(),
16361636
getOptions().getClock(),
16371637
EMPTY_RETRY_CONFIG,
16381638
getOptions().isOpenTelemetryTracingEnabled(),

0 commit comments

Comments
 (0)