You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2017/01/29 16:21:48 UTC
[02/50] beam git commit: [BEAM-1258] demote retrying loggings to info
level.
[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 <pe...@google.com>
Authored: Tue Jan 24 11:09:09 2017 -0800
Committer: Dan Halperin <dh...@google.com>
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(