diff --git a/lib/src/main/java/com/cloudera/labs/envelope/output/JdbcOutput.java b/lib/src/main/java/com/cloudera/labs/envelope/output/JdbcOutput.java
index 3b4fe1c..2d6de46 100644
--- a/lib/src/main/java/com/cloudera/labs/envelope/output/JdbcOutput.java
+++ b/lib/src/main/java/com/cloudera/labs/envelope/output/JdbcOutput.java
@@ -24,6 +24,7 @@
 import com.typesafe.config.ConfigValueType;
 import org.apache.spark.sql.Dataset;
 import org.apache.spark.sql.Row;
+import org.apache.spark.sql.SaveMode;
 import scala.Tuple2;
 
 import java.util.List;
@@ -66,7 +67,7 @@ public void applyBulkMutations(List<Tuple2<MutationType, Dataset<Row>>> planned)
       Dataset<Row> mutation = plan._2();
       switch (mutationType) {
         case INSERT:
-          mutation.write().jdbc(url, tableName, properties);
+          mutation.write().mode(SaveMode.Append).jdbc(url, tableName, properties);
           break;
         default:
           throw new RuntimeException("JDBC output does not support mutation type: " + mutationType);