beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [1/2] beam git commit: WriteFiles: trivial message fix
Date Fri, 28 Apr 2017 00:21:04 GMT
Repository: beam
Updated Branches:
  refs/heads/master f71395bfd -> 674ae9a47


WriteFiles: trivial message fix


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

Branch: refs/heads/master
Commit: 95fdb8f4dbb6bb8ec6d80152aa85cc970ab13366
Parents: f71395b
Author: Dan Halperin <dhalperi@google.com>
Authored: Thu Apr 27 13:51:53 2017 -0700
Committer: Dan Halperin <dhalperi@google.com>
Committed: Thu Apr 27 16:57:42 2017 -0700

----------------------------------------------------------------------
 .../core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/95fdb8f4/sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java
index 4f45cc9..2787820 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java
@@ -534,8 +534,8 @@ public class WriteFiles<T> extends PTransform<PCollection<T>,
PDone> {
               int extraShardsNeeded = minShardsNeeded - results.size();
               if (extraShardsNeeded > 0) {
                 LOG.info(
-                    "Creating {} empty output shards in addition to {} written for a total
of "
-                        + " {}.", extraShardsNeeded, results.size(), minShardsNeeded);
+                    "Creating {} empty output shards in addition to {} written for a total
of {}.",
+                    extraShardsNeeded, results.size(), minShardsNeeded);
                 for (int i = 0; i < extraShardsNeeded; ++i) {
                   FileBasedWriter<T> writer = writeOperation.createWriter(c.getPipelineOptions());
                   writer.openUnwindowed(UUID.randomUUID().toString(), UNKNOWN_SHARDNUM,


Mime
View raw message