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)