[
https://issues.apache.org/jira/browse/APEXMALHAR-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bhupesh Chawda updated APEXMALHAR-1985:
---------------------------------------
Fix Version/s: 3.4.0
> 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
> Fix For: 3.4.0
>
>
> 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)
