Merge pull request #348 from data-integrations/exc_handling

[PLUGIN-1514] When database write transaction failed we should fail the pipeline

Author: tivv

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

@@ -115,7 +115,7 @@ public void close(TaskAttemptContext context) throws IOException {
         }
 
         @Override
-        public void write(K key, V value) {
+        public void write(K key, V value) throws IOException {
           emptyData = false;
           //We need to make correct logging to avoid losing information about error
           try {
@@ -129,7 +129,7 @@ public void write(K key, V value) {
               getStatement().executeBatch();
             }
           } catch (SQLException e) {
-            LOG.warn("Failed to write value to database", e);
+            throw new IOException(e);
           }
         }
       };