Repository: sqoop Updated Branches: refs/heads/trunk 5d8152eac -> 408358930
SQOOP-2617. Log file that is being used for LOB files (Jarcec via Hari) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/40835893 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/40835893 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/40835893 Branch: refs/heads/trunk Commit: 408358930d6fad9ee5b4c75887dda9cedc0ff61d Parents: 5d8152e Author: Hari Shreedharan <[email protected]> Authored: Thu Oct 15 13:55:17 2015 -0700 Committer: Hari Shreedharan <[email protected]> Committed: Thu Oct 15 13:56:07 2015 -0700 ---------------------------------------------------------------------- src/java/org/apache/sqoop/lib/LargeObjectLoader.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/40835893/src/java/org/apache/sqoop/lib/LargeObjectLoader.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/sqoop/lib/LargeObjectLoader.java b/src/java/org/apache/sqoop/lib/LargeObjectLoader.java index 99ad9e7..70c0f4e 100644 --- a/src/java/org/apache/sqoop/lib/LargeObjectLoader.java +++ b/src/java/org/apache/sqoop/lib/LargeObjectLoader.java @@ -29,6 +29,9 @@ import java.sql.Clob; import java.sql.ResultSet; import java.sql.SQLException; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; + import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; @@ -48,6 +51,8 @@ import com.cloudera.sqoop.util.TaskId; */ public class LargeObjectLoader implements Closeable { + public static final Log LOG = LogFactory.getLog(LargeObjectLoader.class.getName()); + // Spill to external storage for BLOB/CLOB objects > 16 MB. public static final long DEFAULT_MAX_LOB_LENGTH = 16 * 1024 * 1024; @@ -117,6 +122,7 @@ public class LargeObjectLoader implements Closeable { private Path getNextLobFilePath() throws IOException { Path p = new Path(workPath, getNextLobFileName()); Path parent = p.getParent(); + LOG.info("Using lob file: " + p.toString()); if (!fs.exists(parent)) { fs.mkdirs(parent); }
