diff --git a/azkaban-common/src/main/java/azkaban/project/JdbcProjectLoader.java b/azkaban-common/src/main/java/azkaban/project/JdbcProjectLoader.java
index d726216..3c1ea14 100644
--- a/azkaban-common/src/main/java/azkaban/project/JdbcProjectLoader.java
+++ b/azkaban-common/src/main/java/azkaban/project/JdbcProjectLoader.java
@@ -402,9 +402,10 @@ public class JdbcProjectLoader extends AbstractJdbcLoader implements
logger.info("Running update for " + filename + " chunk " + chunk);
runner.update(connection, INSERT_PROJECT_FILES, project.getId(),
version, chunk, size, buf);
+ connection.commit();
logger.info("Finished update for " + filename + " chunk " + chunk);
} catch (SQLException e) {
- throw new ProjectManagerException("Error chunking", e);
+ throw new ProjectManagerException("Error Chunking during uploading files to db...");
}
++chunk;