[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 <[email protected]> Authored: Fri May 5 19:06:03 2017 -0700 Committer: Dan Halperin <[email protected]> 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);
