beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [1/2] incubator-beam git commit: FileBasedSink: fix a format string bug
Date Mon, 09 May 2016 17:23:42 GMT
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 <dhalperi@google.com>
Authored: Mon May 9 09:33:36 2016 -0700
Committer: Dan Halperin <dhalperi@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);


Mime
View raw message