Updated Branches: refs/heads/trunk 8c3c78b11 -> 4aa174abe
SQOOP-856: PGBulkLoadExportMapper has an infinite waitFor without any logging in the event of Interrupted exceptions (Venkat Ranganathan via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/4aa174ab Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/4aa174ab Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/4aa174ab Branch: refs/heads/trunk Commit: 4aa174abee0fc2b8bfb407a4fc5829e22b746413 Parents: 8c3c78b Author: Jarek Jarcec Cecho <[email protected]> Authored: Tue Feb 26 17:24:39 2013 -0800 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Tue Feb 26 17:24:39 2013 -0800 ---------------------------------------------------------------------- .../sqoop/mapreduce/PGBulkloadExportMapper.java | 6 ++++++ 1 files changed, 6 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/4aa174ab/src/java/org/apache/sqoop/mapreduce/PGBulkloadExportMapper.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/sqoop/mapreduce/PGBulkloadExportMapper.java b/src/java/org/apache/sqoop/mapreduce/PGBulkloadExportMapper.java index 86c5e02..6c8d806 100644 --- a/src/java/org/apache/sqoop/mapreduce/PGBulkloadExportMapper.java +++ b/src/java/org/apache/sqoop/mapreduce/PGBulkloadExportMapper.java @@ -226,6 +226,12 @@ public class PGBulkloadExportMapper } } catch (InterruptedException ie) { // interrupted; loop around. + LOG.debug("Caught interrupted exception waiting for process " + + "pg_bulkload.bin to exit"); + //Clear the interrupted flag. We have to call Thread.interrupted + //to clear for interrupted exceptions from process.waitFor + //See http://bugs.sun.com/view_bug.do?bug_id=6420270 for more info + Thread.interrupted(); continue; } break;
