diff --git a/src/java/org/apache/sqoop/manager/PostgresqlManager.java b/src/java/org/apache/sqoop/manager/PostgresqlManager.java index 609a457c..bd882b90 100644 --- a/src/java/org/apache/sqoop/manager/PostgresqlManager.java +++ b/src/java/org/apache/sqoop/manager/PostgresqlManager.java @@ -96,7 +96,7 @@ protected String escapeIdentifier(String identifier) { @Override public void close() throws SQLException { if (this.hasOpenConnection()) { - this.getConnection().commit(); // Commit any changes made thus far. + this.getConnection().rollback(); // rollback any pending changes. } super.close();