| commit | ffcc5e03e0f745ce1575282ce8b809b177e4048b | [log] [tgz] |
|---|---|---|
| author | Tomo Suzuki <suztomo@google.com> | Mon Apr 19 10:09:56 2021 -0400 |
| committer | GitHub <noreply@github.com> | Mon Apr 19 10:09:56 2021 -0400 |
| tree | 33259439f29320040f23da34d1fd81b4d902a7ee | |
| parent | a89879f81e5d2e7a365ad030fc909dbd50abe68e [diff] | |
| parent | dc665d51af48799b2f74292f801c77374c9689a3 [diff] |
Merge pull request #14546 : [BEAM-12173] use toMinutes
diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java index f648f72..290dca2 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java
@@ -632,7 +632,7 @@ table.getTableReference().getProjectId(), table.getTableReference().getDatasetId(), table.getTableReference().getTableId(), - TimeUnit.MILLISECONDS.toSeconds(RETRY_CREATE_TABLE_DURATION_MILLIS) / 60.0); + TimeUnit.MILLISECONDS.toMinutes(RETRY_CREATE_TABLE_DURATION_MILLIS)); retry = true; } continue;
diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImplTest.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImplTest.java index 4877d86..286df98 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImplTest.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImplTest.java
@@ -1063,7 +1063,7 @@ verifyNotNull(ret.getTableReference()); expectedLogs.verifyInfo( "Quota limit reached when creating table project:dataset.table, " - + "retrying up to 5.0 minutes"); + + "retrying up to 5 minutes"); } /** Tests that {@link DatasetServiceImpl#insertAll} uses the supplied {@link ErrorContainer}. */