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 <dhalp...@google.com> Authored: Mon May 9 09:33:36 2016 -0700 Committer: Dan Halperin <dhalp...@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);
