sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jar...@apache.org
Subject git commit: SQOOP-856: PGBulkLoadExportMapper has an infinite waitFor without any logging in the event of Interrupted exceptions
Date Wed, 27 Feb 2013 01:25:15 GMT
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 <jarcec@apache.org>
Authored: Tue Feb 26 17:24:39 2013 -0800
Committer: Jarek Jarcec Cecho <jarcec@apache.org>
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;


Mime
View raw message