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 2016/05/09 17:23:42 UTC
[1/2] incubator-beam git commit: FileBasedSink: fix a format string
bug
Repository: incubator-beam
Updated Branches:
refs/heads/master 7725a47a7 -> da1b7556b
FileBasedSink: fix a format string bug
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3ff02950
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3ff02950
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3ff02950
Branch: refs/heads/master
Commit: 3ff02950f7bee4581ec8fd36f57f8755743c4ce0
Parents: 7725a47
Author: Dan Halperin <dh...@google.com>
Authored: Mon May 9 09:33:36 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Mon May 9 10:23:33 2016 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/beam/sdk/io/FileBasedSink.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/3ff02950/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java
index 7d23e7b..23ccdd0 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java
@@ -625,8 +625,9 @@ public abstract class FileBasedSink<T> extends Sink<T> {
public void copy(List<String> srcFilenames, List<String> destFilenames) throws IOException {
Preconditions.checkArgument(
srcFilenames.size() == destFilenames.size(),
- String.format("Number of source files {} must equal number of destination files {}",
- srcFilenames.size(), destFilenames.size()));
+ "Number of source files %s must equal number of destination files %s",
+ srcFilenames.size(),
+ destFilenames.size());
int numFiles = srcFilenames.size();
for (int i = 0; i < numFiles; i++) {
String src = srcFilenames.get(i);
[2/2] incubator-beam git commit: Closes #306
Posted by dh...@apache.org.
Closes #306
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/da1b7556
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/da1b7556
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/da1b7556
Branch: refs/heads/master
Commit: da1b7556b577ee31daea8185faa0da5743990d9e
Parents: 7725a47 3ff0295
Author: Dan Halperin <dh...@google.com>
Authored: Mon May 9 10:23:34 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Mon May 9 10:23:34 2016 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/beam/sdk/io/FileBasedSink.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------