[BEAM-1258] demote retrying loggings to info level.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3afdc5c0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3afdc5c0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3afdc5c0 Branch: refs/heads/python-sdk Commit: 3afdc5c0ef37e48b1750f70e54cd64f5063da83b Parents: 2a23e8b Author: Pei He <[email protected]> Authored: Tue Jan 24 11:09:09 2017 -0800 Committer: Dan Halperin <[email protected]> Committed: Tue Jan 24 12:25:22 2017 -0800 ---------------------------------------------------------------------- .../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/3afdc5c0/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java ---------------------------------------------------------------------- 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 c9edf7c..c524ce4 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 @@ -220,11 +220,11 @@ class BigQueryServicesImpl implements BigQueryServices { return; // SUCCEEDED } // ignore and retry - LOG.warn("Ignore the error and retry inserting the job.", e); + LOG.info("Ignore the error and retry inserting the job.", e); lastException = e; } catch (IOException e) { // ignore and retry - LOG.warn("Ignore the error and retry inserting the job.", e); + LOG.info("Ignore the error and retry inserting the job.", e); lastException = e; } } while (nextBackOff(sleeper, backoff)); @@ -261,7 +261,7 @@ class BigQueryServicesImpl implements BigQueryServices { // The job is not DONE, wait longer and retry. } catch (IOException e) { // ignore and retry - LOG.warn("Ignore the error and retry polling job status.", e); + LOG.info("Ignore the error and retry polling job status.", e); } } while (nextBackOff(sleeper, backoff)); LOG.warn("Unable to poll job status: {}, aborting after reached max .", jobRef.getJobId()); @@ -316,12 +316,12 @@ class BigQueryServicesImpl implements BigQueryServices { LOG.info("No BigQuery job with job id {} found.", jobId); return null; } - LOG.warn( + LOG.info( "Ignoring the error encountered while trying to query the BigQuery job {}", jobId, e); lastException = e; } catch (IOException e) { - LOG.warn( + LOG.info( "Ignoring the error encountered while trying to query the BigQuery job {}", jobId, e); lastException = e; @@ -618,10 +618,10 @@ class BigQueryServicesImpl implements BigQueryServices { return; // SUCCEEDED } // ignore and retry - LOG.warn("Ignore the error and retry creating the dataset.", e); + LOG.info("Ignore the error and retry creating the dataset.", e); lastException = e; } catch (IOException e) { - LOG.warn("Ignore the error and retry creating the dataset.", e); + LOG.info("Ignore the error and retry creating the dataset.", e); lastException = e; } } while (nextBackOff(sleeper, backoff)); @@ -891,7 +891,7 @@ class BigQueryServicesImpl implements BigQueryServices { if (!shouldRetry.apply(e)) { break; } - LOG.warn("Ignore the error and retry the request.", e); + LOG.info("Ignore the error and retry the request.", e); } } while (nextBackOff(sleeper, backoff)); throw new IOException(
