apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Priyanka Gugale (JIRA)" <j...@apache.org>
Subject [jira] [Created] (APEXMALHAR-1985) Cassandra Input Oeprator startRow set incorrectly
Date Wed, 27 Jan 2016 10:56:39 GMT
Priyanka Gugale created APEXMALHAR-1985:

             Summary: Cassandra Input Oeprator startRow set incorrectly
                 Key: APEXMALHAR-1985
                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-1985
             Project: Apache Apex Malhar
          Issue Type: Bug
            Reporter: Priyanka Gugale
            Assignee: Priyanka Gugale

The CassandraInputOperator scans the table starting with StratRow, at end of each query, it
updates start row to the last scanned row in current query.
The query format is: select * from %t where token(%p) > %v limit %l

Where %v is set to primary column value, but instead it should be set to token value of start
row i.e. 
%v = token(startRow).

Reference: http://mail-archives.apache.org/mod_mbox/cassandra-user/201308.mbox/%3CCA+VSrLpeZqSv_85YqqR-99F-q2PMv2LAJ825WZrL7MEAf_jxFw@mail.gmail.com%3E

This message was sent by Atlassian JIRA

View raw message