[jira] [Commented] (BAHIR-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite

[ASF GitHub Bot (JIRA)]

    [ 
https://issues.apache.org/jira/browse/BAHIR-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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.
    + * <p>
    + * 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
    + * <p>
    + * http://www.apache.org/licenses/LICENSE-2.0
    + * <p>
    + * 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)