beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Alexander Dejanovski (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (BEAM-3485) CassandraIO.read() splitting produces invalid queries
Date Fri, 13 Apr 2018 14:11:00 GMT

    [ https://issues.apache.org/jira/browse/BEAM-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16437344#comment-16437344
] 

Alexander Dejanovski commented on BEAM-3485:
--------------------------------------------

Neat !

It's fixed.

> CassandraIO.read() splitting produces invalid queries
> -----------------------------------------------------
>
>                 Key: BEAM-3485
>                 URL: https://issues.apache.org/jira/browse/BEAM-3485
>             Project: Beam
>          Issue Type: Bug
>          Components: io-java-cassandra
>            Reporter: Eugene Kirpichov
>            Assignee: Alexey Romanenko
>            Priority: Major
>          Time Spent: 1h 20m
>  Remaining Estimate: 0h
>
> See [https://stackoverflow.com/questions/48090668/how-to-increase-dataflow-read-parallelism-from-cassandra/48131264?noredirect=1#comment83548442_48131264]
> As the question author points out, the error is likely that token($pk) should be token(pk).
This was likely masked by BEAM-3424 and BEAM-3425, and the splitting code path effectively
was never invoked, and was broken from the first PR - so there are likely other bugs.
> When testing this issue, we must ensure good code coverage in an IT against a real Cassandra
instance.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message