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/03/24 22:57:08 UTC

[1/2] beam git commit: BigtableIO: trivial fixes to log messages

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 <dh...@google.com>
Authored: Fri Mar 24 14:54:39 2017 -0700
Committer: Dan Halperin <dh...@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,


[2/2] beam git commit: This closes #2324

Posted by dh...@apache.org.
This closes #2324


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d63235cb
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d63235cb
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d63235cb

Branch: refs/heads/master
Commit: d63235cb5fc623e75db9d7e45e7284c1138812e6
Parents: c80ef18 fe352a3
Author: Dan Halperin <dh...@google.com>
Authored: Fri Mar 24 15:57:00 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Fri Mar 24 15:57:00 2017 -0700

----------------------------------------------------------------------
 .../java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------