[
https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16298718#comment-16298718
]
ASF subversion and git services commented on BAHIR-128:
-------------------------------------------------------
Commit 0e1505a8960bfe40ea025267bbf36ec5c4cf5c79 in bahir's branch
refs/heads/master from [~emlaver]
[ https://git-wip-us.apache.org/repos/asf?p=bahir.git;h=0e1505a ]
[BAHIR-128] Improve sql-cloudant _changes receiver
This change improves the stability of _changes receiver and
fix the intermitent failing test in sql-cloudant's
CloudantChangesDFSuite.
How
Improve performance and decrease testing time by setting batch size
to 8 seconds and using seq_interval _changes feed option.
Use getResource to load json files path
Added Mike Rhodes's ChangesRowScanner for reading each _changes line
and transforming to GSON's JSON object
Added Mike Rhodes's ChangesRow representing a row in the changes feed
Closes #57
> Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
> ------------------------------------------------------------------
>
> Key: BAHIR-128
> URL: https://issues.apache.org/jira/browse/BAHIR-128
> Project: Bahir
> Issue Type: Bug
> Reporter: Esteban Laver
> Assignee: Esteban Laver
> Priority: Minor
>
> This failure happened during pre-release testing for Bahir RC 2.2.0:
> CloudantChangesDFSuite:
> - load and save data from Cloudant database *** FAILED ***
> 0 did not equal 1967 (CloudantChangesDFSuite.scala:49)
> Partial stack trace:
> {code:java}
> Exception in thread "Cloudant Receiver" org.apache.spark.SparkException:
> Cannot add data as BlockGenerator has not been started or has been stopped
> at
> org.apache.spark.streaming.receiver.BlockGenerator.addData(BlockGenerator.scala:173)
> at
> org.apache.spark.streaming.receiver.ReceiverSupervisorImpl.pushSingle(ReceiverSupervisorImpl.scala:120)
> at org.apache.spark.streaming.receiver.Receiver.store(Receiver.scala:119)
> at
> org.apache.bahir.cloudant.internal.ChangesReceiver$$anonfun$org$apache$bahir$cloudant$internal$ChangesReceiver$$receive$1$$anonfun$apply$1.apply(ChangesReceiver.scala:82)
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
