[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298721#comment-16298721 ] ASF GitHub Bot commented on BAHIR-128: -- Github user asfgit closed the pull request at: https://github.com/apache/bahir/pull/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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298705#comment-16298705 ] ASF GitHub Bot commented on BAHIR-128: -- Github user mikerhodes commented on the issue: https://github.com/apache/bahir/pull/57 I'm +1 on this PR including the code I originally wrote. Pleased to see it get use in the wild :) > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297870#comment-16297870 ] ASF GitHub Bot commented on BAHIR-128: -- Github user lresende commented on the issue: https://github.com/apache/bahir/pull/57 LGTM Merging if there are no other comments > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295346#comment-16295346 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295322#comment-16295322 ] ASF GitHub Bot commented on BAHIR-128: -- Github user emlaver commented on a diff in the pull request: https://github.com/apache/bahir/pull/57#discussion_r157553098 --- Diff: sql-cloudant/src/main/scala/org/apache/bahir/cloudant/CloudantChangesConfig.scala --- @@ -67,7 +67,8 @@ class CloudantChangesConfig(protocol: String, host: String, dbName: String, } def getChangesReceiverUrl: String = { -var url = dbUrl + "/" + defaultIndex + "?include_docs=true=continuous=" + timeout +var url = dbUrl + "/" + defaultIndex + "?include_docs=true=normal" + + "_interval=1=" + timeout --- End diff -- Yes, I think that's a good idea. Fixed in f758996. > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294965#comment-16294965 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ricellis commented on a diff in the pull request: https://github.com/apache/bahir/pull/57#discussion_r157480164 --- 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 -- I'm amazed this parameter was hard-coded as it seems to be a fairly critical tuning parameter for streaming. I guess this is one for another PR. > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294966#comment-16294966 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ricellis commented on a diff in the pull request: https://github.com/apache/bahir/pull/57#discussion_r157484722 --- Diff: sql-cloudant/src/main/scala/org/apache/bahir/cloudant/internal/ChangesReceiver.scala --- @@ -39,56 +37,38 @@ class ChangesReceiver(config: CloudantChangesConfig) } private def receive(): Unit = { -// Get total number of docs in database using _all_docs endpoint -val limit = new JsonStoreDataAccess(config) - .getTotalRows(config.getTotalUrl, queryUsed = false) - -// Get continuous _changes url +// Get normal _changes url --- End diff -- I'm a bit confused about this change. Since Spark Streaming is the basis for "real-time" or "continuous applications" doesn't this need to keep listening to the changes feed to wait for more changes? > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294963#comment-16294963 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ricellis commented on a diff in the pull request: https://github.com/apache/bahir/pull/57#discussion_r157478713 --- Diff: sql-cloudant/src/main/scala/org/apache/bahir/cloudant/CloudantChangesConfig.scala --- @@ -67,7 +67,8 @@ class CloudantChangesConfig(protocol: String, host: String, dbName: String, } def getChangesReceiverUrl: String = { -var url = dbUrl + "/" + defaultIndex + "?include_docs=true=continuous=" + timeout +var url = dbUrl + "/" + defaultIndex + "?include_docs=true=normal" + + "_interval=1=" + timeout --- End diff -- WDYT about making the `seq_interval` the `bulkSize` instead of hard-coding? > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294964#comment-16294964 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ricellis commented on a diff in the pull request: https://github.com/apache/bahir/pull/57#discussion_r157479639 --- Diff: sql-cloudant/src/main/scala/org/apache/bahir/cloudant/internal/ChangesReceiver.scala --- @@ -39,56 +37,38 @@ class ChangesReceiver(config: CloudantChangesConfig) } private def receive(): Unit = { -// Get total number of docs in database using _all_docs endpoint -val limit = new JsonStoreDataAccess(config) - .getTotalRows(config.getTotalUrl, queryUsed = false) - -// Get continuous _changes url +// Get normal _changes url val url = config.getChangesReceiverUrl.toString val selector: String = { "{\"selector\":" + config.getSelector + "}" } -var count = 0 +// var count = 0 --- End diff -- delete? > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16288160#comment-16288160 ] ASF GitHub Bot commented on BAHIR-128: -- Github user emlaver commented on the issue: https://github.com/apache/bahir/pull/57 @ckadner I've got those changes on another branch that still needs a bit more testing. I'll open a PR with the separate ticket once it's ready. > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16287170#comment-16287170 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on the issue: https://github.com/apache/bahir/pull/57 After more than 10 successful builds I'd say that the flaky `sql-cloudant` tests are more stable now than they have ever been. Good work @emlaver. Once you have confirmed that there is no conflict with the copyright for the new code I am happy to merge this. > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16287154#comment-16287154 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16287155#comment-16287155 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/138/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16287139#comment-16287139 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/137/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16287138#comment-16287138 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :red_circle: Build failed, see build log for details > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16287050#comment-16287050 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/134/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16287043#comment-16287043 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/133/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16287042#comment-16287042 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16287035#comment-16287035 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16287064#comment-16287064 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16287065#comment-16287065 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/135/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16287036#comment-16287036 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/132/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286996#comment-16286996 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/131/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286995#comment-16286995 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286984#comment-16286984 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/130/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286973#comment-16286973 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/129/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286972#comment-16286972 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286960#comment-16286960 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on the issue: https://github.com/apache/bahir/pull/57 retest this please > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286927#comment-16286927 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/128/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286926#comment-16286926 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286915#comment-16286915 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Uh oh, @emlaver unless someone else was running the same tests concurrently to the last Jenkins test run, there may still work to be done. retest this please > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286917#comment-16286917 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on the issue: https://github.com/apache/bahir/pull/57 Uh oh, @emlaver unless someone else was running the same tests concurrently to the last Jenkins test run, there may still be some work to be done. > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286894#comment-16286894 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/127/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286893#comment-16286893 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :red_circle: Build failed, see build log for details > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286870#comment-16286870 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on the issue: https://github.com/apache/bahir/pull/57 uh, maybe one more, just to be sure :-) retest this please > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286772#comment-16286772 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on the issue: https://github.com/apache/bahir/pull/57 one more for good emasure retest this please > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286804#comment-16286804 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286805#comment-16286805 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/126/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286769#comment-16286769 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/125/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286745#comment-16286745 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on the issue: https://github.com/apache/bahir/pull/57 retest this please > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286711#comment-16286711 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :red_circle: Build failed, see build log for details > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286690#comment-16286690 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on the issue: https://github.com/apache/bahir/pull/57 retest this please > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286697#comment-16286697 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/123/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286696#comment-16286696 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :red_circle: Build failed, see build log for details > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286625#comment-16286625 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/122/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286140#comment-16286140 ] ASF GitHub Bot commented on BAHIR-128: -- Github user emlaver commented on a diff in the pull request: https://github.com/apache/bahir/pull/57#discussion_r156123828 --- Diff: sql-cloudant/src/main/scala/org/apache/bahir/cloudant/common/ChangesRow.java --- @@ -0,0 +1,74 @@ +/* + * Copyright (c) 2017 IBM Cloudant. All rights reserved. --- End diff -- @ckadner It's valid and the author is OK with this existing in the open-source. From my understanding, we're (Cloudant) allowed to retain the copyright on code we open source, but the license effectively grants free use. > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285299#comment-16285299 ] ASF GitHub Bot commented on BAHIR-128: -- Github user lresende commented on the issue: https://github.com/apache/bahir/pull/57 @emlaver Could you please rebase to latest master. > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285052#comment-16285052 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on a diff in the pull request: https://github.com/apache/bahir/pull/57#discussion_r155936326 --- Diff: sql-cloudant/src/main/scala/org/apache/bahir/cloudant/common/ChangesRow.java --- @@ -0,0 +1,74 @@ +/* + * Copyright (c) 2017 IBM Cloudant. All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file + * except in compliance with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the + * License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, + * either express or implied. See the License for the specific language governing permissions + * and limitations under the License. + */ +package org.apache.bahir.cloudant.common; + +import com.google.gson.JsonElement; +import com.google.gson.JsonObject; + +import java.util.List; + +/** + * Class representing a single row in a changes feed. Structure: + * + * { + * last_seq": 5 + * "results": [ + * ---*** This next items is the ChangesRow ***--- + * { + * "changes": [ {"rev": "2-eec205a9d413992850a6e32678485900"}, ... ], + * "deleted": true, + * "id": "deleted", + * "seq": 5, + * "doc": ... structure ... + * } + * ] + * } + */ +public class ChangesRow { --- End diff -- @emlaver -- Java sources should reside under `src/main/java` not `src/main/scala` unless you can convert this code to Scala (preferably) > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285049#comment-16285049 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on the issue: https://github.com/apache/bahir/pull/57 Very odd that the RAT license checks succeeded. Apparently it is our `scalastyle` checks which complain about any non-conformant license headers, but those don't cover `*.java` files, so I need to update our `checkstyle` rules for Java sources. But I am still puzzled about RAT letting this pass (@lresende) > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285045#comment-16285045 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285040#comment-16285040 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on the issue: https://github.com/apache/bahir/pull/57 I just enabled the RAT check for our Jenkins PR builder. restest this please > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285035#comment-16285035 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/119/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285034#comment-16285034 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285032#comment-16285032 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on a diff in the pull request: https://github.com/apache/bahir/pull/57#discussion_r155934996 --- Diff: sql-cloudant/src/main/scala/org/apache/bahir/cloudant/common/ChangesRowScanner.java --- @@ -0,0 +1,92 @@ +/* + * Copyright (c) 2017 IBM Cloudant. All rights reserved. + * --- End diff -- same [comment](https://github.com/apache/bahir/pull/57/commits/5e554103bee8162b85948e219dd4b7fdd7707a30#r155934979) as above > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285028#comment-16285028 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on the issue: https://github.com/apache/bahir/pull/57 retest this please > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284639#comment-16284639 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284607#comment-16284607 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/117/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284601#comment-16284601 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 :white_check_mark: Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284603#comment-16284603 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Build started sha1 is merged. > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284594#comment-16284594 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Build triggered. sha1 is merged. > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284591#comment-16284591 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Build triggered. sha1 is merged. > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284592#comment-16284592 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Build started sha1 is merged. > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283914#comment-16283914 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/115/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283913#comment-16283913 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Build failed, see build log for details > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283840#comment-16283840 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Build failed, see build log for details > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283757#comment-16283757 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/113/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283029#comment-16283029 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283024#comment-16283024 ] ASF GitHub Bot commented on BAHIR-128: -- Github user emlaver commented on a diff in the pull request: https://github.com/apache/bahir/pull/57#discussion_r155699572 --- Diff: pom.xml --- @@ -458,7 +458,7 @@ .gitignore .repository/ - .idea/ + **/.idea/** --- End diff -- Yea, I think it's extra files in my IntelliJ setup. I'll rebased my changes. > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283015#comment-16283015 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Build successful > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283016#comment-16283016 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Refer to this link for build results (access rights to CI server needed): http://169.45.79.58:8080/job/bahir_spark_pr_builder/111/ > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282996#comment-16282996 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on the issue: https://github.com/apache/bahir/pull/57 ok to test > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282994#comment-16282994 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ckadner commented on a diff in the pull request: https://github.com/apache/bahir/pull/57#discussion_r155697683 --- Diff: pom.xml --- @@ -458,7 +458,7 @@ .gitignore .repository/ - .idea/ + **/.idea/** --- End diff -- this change should not be necessary. the `.idea/` folder should only get created at the project root level. any nested files and folders are already covered. maybe a mishap when setting up IntelliJ? > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282960#comment-16282960 ] ASF GitHub Bot commented on BAHIR-128: -- GitHub user emlaver opened a pull request: https://github.com/apache/bahir/pull/57 [BAHIR-128][WIP] fix failing sql-cloudant test _What_ Fix test that's failing sporadically in sql-cloudant's `CloudantChangesDFSuite`. _How_ - Call stop in receiver when _changes feed completes - Improve performance and decrease testing time by setting batch size to 8 seconds - Use getResource to load json files path See [BAHIR-128](https://issues.apache.org/jira/browse/BAHIR-128) You can merge this pull request into a Git repository by running: $ git pull https://github.com/emlaver/bahir 128-fix-failing-sql-cloudant-test Alternatively you can review and apply these changes as the patch at: https://github.com/apache/bahir/pull/57.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #57 commit cab516bbf42a5a40d7fa4f7d1813772ecd39105c Author: Esteban LaverDate: 2017-09-08T14:33:26Z - Call stop in receiver when _changes feed completes - Improved performance and decrease testing time by setting batch size to 8 seconds - Use getResource to load json files path > 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)
[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite
[ https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282961#comment-16282961 ] ASF GitHub Bot commented on BAHIR-128: -- Github user ApacheBahir commented on the issue: https://github.com/apache/bahir/pull/57 Can one of the admins verify this patch? > 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)