Github user emlaver commented on a diff in the pull request:
https://github.com/apache/bahir/pull/57#discussion_r157532385
--- Diff:
sql-cloudant/src/main/scala/org/apache/bahir/cloudant/DefaultSource.scala ---
@@ -125,7 +125,7 @@ class DefaultSource extends RelationProvider
/* Create a streaming context to handle transforming docs in
* larger databases into Spark datasets
*/
- val ssc = new StreamingContext(sqlContext.sparkContext,
Seconds(10))
+ val ssc = new StreamingContext(sqlContext.sparkContext,
Seconds(8))
--- End diff --
Yes, this was not visible as part of the initial internal `_changes` work.
I will create a new JIRA item and PR for this.
---
