Repository: beam Updated Branches: refs/heads/master c80ef1837 -> d63235cb5
BigtableIO: trivial fixes to log messages Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fe352a30 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fe352a30 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fe352a30 Branch: refs/heads/master Commit: fe352a30e08c748ba191b767b28de506913b02c1 Parents: c80ef18 Author: Dan Halperin <dhalp...@google.com> Authored: Fri Mar 24 14:54:39 2017 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Fri Mar 24 14:54:39 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/fe352a30/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java index a052e09..2cdd11d 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java @@ -1007,7 +1007,7 @@ public class BigtableIO { splitKey = rangeTracker.getRange().interpolateKey(fraction); } catch (RuntimeException e) { LOG.info( - "%s: Failed to interpolate key for fraction %s.", rangeTracker.getRange(), fraction, e); + "{}: Failed to interpolate key for fraction {}.", rangeTracker.getRange(), fraction, e); return null; } LOG.debug( @@ -1019,7 +1019,7 @@ public class BigtableIO { residual = source.withStartKey(splitKey); } catch (RuntimeException e) { LOG.info( - "%s: Interpolating for fraction %s yielded invalid split key %s.", + "{}: Interpolating for fraction {} yielded invalid split key {}.", rangeTracker.getRange(), fraction, splitKey,