[
https://issues.apache.org/jira/browse/APEXMALHAR-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121045#comment-15121045
]
ASF GitHub Bot commented on APEXMALHAR-1985:
--------------------------------------------
GitHub user DT-Priyanka opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/182
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/182.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 #182
----
commit d1845882e426d7fa9fadb24d11c15f9d152eacdb
Author: Priyanka Gugale <[email protected]>
Date: 2016-01-27T12:25:57Z
APEXMALHAR-1985: Using startRow to fetch startRowToken
commit 4070b575d1ba93b7650a2d527eed8d473ed2510e
Author: Priyanka Gugale <[email protected]>
Date: 2016-01-28T08:47:31Z
Adding null check for startRow token value
----
> 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)
