github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-06 09:49:10 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-1128: Sqoop2: SqoopException being nested into another SqoopException in Repository

Browse Source 
(Mengwei Ding via Venkat Ranganathan)
This commit is contained in:
Venkat Ranganathan 2013-07-08 20:14:08 -07:00
parent 96a02dfee9
commit 251c8334fa
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
core/src/main/java/org/apache/sqoop/repository/Repository.java
View File

@ -464,6 +464,11 @@ public final void upgradeConnector(MConnector oldConnector, MConnector newConnec
throw new SqoopException(RepositoryError.JDBCREPO_0027, msg); throw new SqoopException(RepositoryError.JDBCREPO_0027, msg);
} }
} catch (SqoopException ex) {
if(tx != null) {
tx.rollback();
}
throw ex;
} catch (Exception ex) { } catch (Exception ex) {
if(tx != null) { if(tx != null) {
tx.rollback(); tx.rollback();
@ -558,6 +563,11 @@ public final void upgradeFramework(MFramework framework) {
throw new SqoopException(RepositoryError.JDBCREPO_0027, msg); throw new SqoopException(RepositoryError.JDBCREPO_0027, msg);
} }
} catch (SqoopException ex) {
if(tx != null) {
tx.rollback();
}
throw ex;
} catch (Exception ex) { } catch (Exception ex) {
if(tx != null) { if(tx != null) {
tx.rollback(); tx.rollback();