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)
