Re: Missing rows while scanning table using java driver

[Ryan Svihla <rs...@foundev.pro>]

Priyanka,

This is a better question for the Cassandra user mailing list (cc’d above) which is where many experts in the use of Cassandra are subscribed, where as this list is more about improving or changing Cassandra itself.

As to your issue, there can be many combined issues at once that are leading to this situation, can I suggest you respond on the user list with the following:

- Keyspace (RF especially), data center and table configuration.
- Any errors in the logs on the Cassandra nodes.

Regards,

Ryan Svihla

> On Feb 2, 2016, at 4:58 AM, Priyanka Gugale <pr...@apache.org> wrote:
> 
> I am using query of the form: select * from %t where token(%p) > %s limit
> %l;
> 
> where t=tablename, %p=primary key, %s=token value of primary key and l=limit
> 
> -Priyanka
> 
> On Mon, Feb 1, 2016 at 6:19 PM, Priyanka Gugale <pr...@apache.org> wrote:
> 
>> Hi,
>> 
>> I am using Cassandra 2.2.0 and cassandra driver 2.1.8. I am trying to scan
>> a table as per suggestions given here
>> <http://www.myhowto.org/bigdata/2013/11/04/scanning-the-entire-cassandra-column-family-with-cql/>,
>> On running the code to fetch records from table, it fetches different
>> number of records on each run. Some times it reads all records from table,
>> and some times some records are missing. As I have observed there is no
>> fixed pattern for missing records.
>> 
>> I have tried to set consistency level to ALL while running select query
>> still I couldn't fetch all records. Is there any known issue? Or am I
>> suppose to do anything more than running simple "select" statement.
>> 
>> Code snippet to fetch data:
>> 
>> SimpleStatement stmt = new SimpleStatement(query);
>> stmt.setConsistencyLevel(ConsistencyLevel.ALL);
>> ResultSet result = session.execute(stmt);
>> if (!result.isExhausted()) {
>>   for (Row row : result) {
>>     process(row);
>>   }
>> }
>> 
>> -Priyanka
>> 

Re: Missing rows while scanning table using java driver

[Priyanka Gugale <pr...@apache.org>]

Thanks Paulo and Ryan, I have moved my question to user mailing list.

-Priyanka

On Tue, Feb 2, 2016 at 6:31 PM, Ryan Svihla <rs...@foundev.pro> wrote:

> Priyanka,
>
> This is a better question for the Cassandra user mailing list (cc’d above)
> which is where many experts in the use of Cassandra are subscribed, where
> as this list is more about improving or changing Cassandra itself.
>
> As to your issue, there can be many combined issues at once that are
> leading to this situation, can I suggest you respond on the user list with
> the following:
>
> - Keyspace (RF especially), data center and table configuration.
> - Any errors in the logs on the Cassandra nodes.
>
> Regards,
>
> Ryan Svihla
>
> > On Feb 2, 2016, at 4:58 AM, Priyanka Gugale <pr...@apache.org> wrote:
> >
> > I am using query of the form: select * from %t where token(%p) > %s limit
> > %l;
> >
> > where t=tablename, %p=primary key, %s=token value of primary key and
> l=limit
> >
> > -Priyanka
> >
> > On Mon, Feb 1, 2016 at 6:19 PM, Priyanka Gugale <pr...@apache.org>
> wrote:
> >
> >> Hi,
> >>
> >> I am using Cassandra 2.2.0 and cassandra driver 2.1.8. I am trying to
> scan
> >> a table as per suggestions given here
> >> <
> http://www.myhowto.org/bigdata/2013/11/04/scanning-the-entire-cassandra-column-family-with-cql/
> >,
> >> On running the code to fetch records from table, it fetches different
> >> number of records on each run. Some times it reads all records from
> table,
> >> and some times some records are missing. As I have observed there is no
> >> fixed pattern for missing records.
> >>
> >> I have tried to set consistency level to ALL while running select query
> >> still I couldn't fetch all records. Is there any known issue? Or am I
> >> suppose to do anything more than running simple "select" statement.
> >>
> >> Code snippet to fetch data:
> >>
> >> SimpleStatement stmt = new SimpleStatement(query);
> >> stmt.setConsistencyLevel(ConsistencyLevel.ALL);
> >> ResultSet result = session.execute(stmt);
> >> if (!result.isExhausted()) {
> >>   for (Row row : result) {
> >>     process(row);
> >>   }
> >> }
> >>
> >> -Priyanka
> >>
>
>