Rollback inflights when using Spark [Streaming] write

2019-05-01 17:20:35 -07:00
parent 57a8b9cc8c
commit 978470af33
1 changed files with 1 additions and 1 deletions
--- 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);
  }