github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-04 01:19:38 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-1210: Exporting data with malformed records causes sqoop2 jobs to hang until killed or they timeout

Browse Source 
(Venkat Ranganathan via Jarek Jarcec Cecho)
This commit is contained in:
Jarek Jarcec Cecho 2013-10-02 09:14:31 -07:00
parent 15c4f80d7a
commit 066f98aee0
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java
View File

@ -166,9 +166,16 @@ public Object readContent(int type) throws InterruptedException {
if (writerFinished) { if (writerFinished) {
return null; return null;
} }
Object content = data.getContent(type); try {
free.release(); Object content = data.getContent(type);
return content; return content;
} catch (Throwable t) {
readerFinished = true;
LOG.error("Caught exception e while getting content ", t);
throw new SqoopException(MapreduceExecutionError.MAPRED_EXEC_0018, t);
} finally {
free.release();
}
} }
} }