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/04/28 00:21:04 UTC
[1/2] beam git commit: WriteFiles: trivial message fix
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 <dh...@google.com>
Authored: Thu Apr 27 13:51:53 2017 -0700
Committer: Dan Halperin <dh...@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,
[2/2] beam git commit: This closes #2755
Posted by dh...@apache.org.
This closes #2755
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/674ae9a4
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/674ae9a4
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/674ae9a4
Branch: refs/heads/master
Commit: 674ae9a475f1f236230697d5cb1c33d36fec49db
Parents: f71395b 95fdb8f
Author: Dan Halperin <dh...@google.com>
Authored: Thu Apr 27 17:20:54 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu Apr 27 17:20:54 2017 -0700
----------------------------------------------------------------------
.../core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------