BugFix

Author: Shubhangi-cs

database-commons/src/main/java/io/cdap/plugin/db/sink/ETLDBOutputFormat.java

@@ -97,8 +97,8 @@ public void close(TaskAttemptContext context) throws IOException {
           try {
             if (!emptyData) {
               getStatement().executeBatch();
-              getConnection().commit();
             }
+            getConnection().commit();
           } catch (SQLException e) {
             try {
               getConnection().rollback();
@@ -135,6 +135,7 @@ public void write(K key, V value) throws IOException {
             // This is done to reduce memory usage in the worker, as processed records can now be GC'd.
             if (batchSize > 0 && numWrittenRecords % batchSize == 0) {
               getStatement().executeBatch();
+              emptyData = true;
             }
           } catch (SQLException e) {
             throw new IOException(e);