You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Eugene Kirpichov (JIRA)" <ji...@apache.org> on 2018/01/16 19:57:00 UTC

[jira] [Created] (BEAM-3485) CassandraIO.read() splitting produces invalid queries

Eugene Kirpichov created BEAM-3485:
--------------------------------------

             Summary: CassandraIO.read() splitting produces invalid queries
                 Key: BEAM-3485
                 URL: https://issues.apache.org/jira/browse/BEAM-3485
             Project: Beam
          Issue Type: Bug
          Components: sdk-java-extensions
            Reporter: Eugene Kirpichov
            Assignee: Jean-Baptiste Onofré


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)