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);
}