gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hut...@apache.org
Subject incubator-gobblin git commit: [GOBBLIN-220] FileAwareInputStreamDataWriter: Add a log statement when we begin file copies so if an exception is thrown it is easy to tie that back to the filename.
Date Tue, 22 Aug 2017 21:44:25 GMT
Repository: incubator-gobblin
Updated Branches:
  refs/heads/master 5f7246004 -> 32ca21a5c


[GOBBLIN-220] FileAwareInputStreamDataWriter: Add a log statement when we begin file copies
so if an
exception is thrown it is easy to tie that back to the filename.

Closes #2071 from eogren/gobblin-220


Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/32ca21a5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/32ca21a5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/32ca21a5

Branch: refs/heads/master
Commit: 32ca21a5c3b0cd697759431b0db34d0dfe26b0f6
Parents: 5f72460
Author: Eric Ogren <eogren@linkedin.com>
Authored: Tue Aug 22 14:44:05 2017 -0700
Committer: Hung Tran <hutran@linkedin.com>
Committed: Tue Aug 22 14:44:05 2017 -0700

----------------------------------------------------------------------
 .../management/copy/writer/FileAwareInputStreamDataWriter.java     | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/32ca21a5/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java
index 905ac02..03fc2b6 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java
@@ -226,6 +226,8 @@ public class FileAwareInputStreamDataWriter extends InstrumentedDataWriter<FileA
             .targetURI(this.fs.makeQualified(writeAt).toUri()).build();
         StreamCopier copier = new StreamCopier(throttledInputStream, os).withBufferSize(this.bufferSize);
 
+        log.info("File {}: Starting copy", copyableFile.getOrigin().getPath());
+
         if (isInstrumentationEnabled()) {
           copier.withCopySpeedMeter(this.copySpeedMeter);
         }


Mime
View raw message