[APEXMALHAR-1985] Cassandra Input Oeprator: startRow set incorrectly

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.4.0
• Assignee: Priyanka Gugale
• Reporter: Priyanka Gugale
• Created: 27/Jan/16 10:55
• Updated: 24/May/16 17:05
• Resolved: 22/Apr/16 13:46

Description

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/[e-mail]%3E