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_j...@mail.gmail.com%3E
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
