From 978470af336c1efd04864c2f0c1eb6a963233f39 Mon Sep 17 00:00:00 2001
From: Balaji Varadarajan <varadarb@uber.com>
Date: Wed, 1 May 2019 17:20:35 -0700
Subject: [PATCH] Rollback inflights when using Spark [Streaming] write

---
 hoodie-spark/src/main/java/com/uber/hoodie/DataSourceUtils.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hoodie-spark/src/main/java/com/uber/hoodie/DataSourceUtils.java b/hoodie-spark/src/main/java/com/uber/hoodie/DataSourceUtils.java
index 3c56a0d02..19352edd4 100644
--- a/hoodie-spark/src/main/java/com/uber/hoodie/DataSourceUtils.java
+++ b/hoodie-spark/src/main/java/com/uber/hoodie/DataSourceUtils.java
@@ -149,7 +149,7 @@ public class DataSourceUtils {
         // override above with Hoodie configs specified as options.
         .withProps(parameters).build();
 
-    return new HoodieWriteClient<>(jssc, writeConfig);
+    return new HoodieWriteClient<>(jssc, writeConfig, true);
   }