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/05/08 18:48:47 UTC
[2/3] beam git commit: [BEAM-2212] FileBasedSource: improve message
when logging.
[BEAM-2212] FileBasedSource: improve message when logging.
ValueProvider should not be printed, rather the string instead.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5bac40ef
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5bac40ef
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5bac40ef
Branch: refs/heads/master
Commit: 5bac40efcc7bcd9d53183579ec6089c23aeda782
Parents: 2b0e699
Author: Dan Halperin <dh...@google.com>
Authored: Fri May 5 19:06:03 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Mon May 8 11:48:39 2017 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/beam/sdk/io/FileBasedSource.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/5bac40ef/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java
index 2beb5e0..4e07342 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java
@@ -268,7 +268,7 @@ public abstract class FileBasedSource<T> extends OffsetBasedSource<T> {
LOG.info(
"Splitting filepattern {} into bundles of size {} took {} ms "
+ "and produced {} files and {} bundles",
- fileOrPatternSpec,
+ fileOrPatternSpec.get(),
desiredBundleSizeBytes,
System.currentTimeMillis() - startTime,
expandedFiles.size(),
@@ -327,7 +327,7 @@ public abstract class FileBasedSource<T> extends OffsetBasedSource<T> {
}
LOG.debug(
"Creating a reader for file pattern {} took {} ms",
- fileOrPatternSpec,
+ fileOrPatternSpec.get(),
System.currentTimeMillis() - startTime);
if (fileReaders.size() == 1) {
return fileReaders.get(0);