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 <[email protected]> Authored: Thu Apr 27 13:51:53 2017 -0700 Committer: Dan Halperin <[email protected]> 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,
