[
https://issues.apache.org/jira/browse/APEXMALHAR-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15219443#comment-15219443
]
ASF GitHub Bot commented on APEXMALHAR-1985:
--------------------------------------------
GitHub user DT-Priyanka opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/226
APEXMALHAR-1985: Using startRow to fetch startRowToken
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/DT-Priyanka/incubator-apex-malhar
APEXMALHAR-1985_cassandra_scan
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-apex-malhar/pull/226.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #226
----
commit f656587f5c1947fc654e07a92cc4102c7cd262a6
Author: Priyanka Gugale <[email protected]>
Date: 2016-01-27T12:25:57Z
APEXMALHAR-1985: Using startRow to fetch startRowToken
----
> 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)
