This is an automated email from the ASF dual-hosted git repository.

vbalaji pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 978470a  Rollback inflights when using Spark [Streaming] write
978470a is described below

commit 978470af336c1efd04864c2f0c1eb6a963233f39
Author: Balaji Varadarajan <[email protected]>
AuthorDate: Wed May 1 17:20:35 2019 -0700

    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 3c56a0d..19352ed 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);
   }
 
 

Reply via email to