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

[ https://issues.apache.org/jira/browse/BEAM-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438364#comment-16438364 ] Alexander Dejanovski commented on BEAM-3485: I've just pushed a new version that allows the

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

[ https://issues.apache.org/jira/browse/BEAM-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437588#comment-16437588 ] Alexander Dejanovski commented on BEAM-3485: # So, out of experience I know that most clusters

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

[ https://issues.apache.org/jira/browse/BEAM-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437513#comment-16437513 ] Alexey Romanenko commented on BEAM-3485: [~adejanovski] 1. BEAM-3424 I agree with what you

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

[ https://issues.apache.org/jira/browse/BEAM-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437344#comment-16437344 ] Alexander Dejanovski commented on BEAM-3485: Neat ! It's fixed. > CassandraIO.read()

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

[ https://issues.apache.org/jira/browse/BEAM-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437332#comment-16437332 ] Alexey Romanenko commented on BEAM-3485: [~adejanovski] Could you run this command locally?

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

[ https://issues.apache.org/jira/browse/BEAM-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437322#comment-16437322 ] Alexander Dejanovski commented on BEAM-3485: Apparently I have test failures triggered by

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

[ https://issues.apache.org/jira/browse/BEAM-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437309#comment-16437309 ] Alexander Dejanovski commented on BEAM-3485: Hi [~aromanenko], yes both BEAM-3424 and

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

[ https://issues.apache.org/jira/browse/BEAM-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437245#comment-16437245 ] Alexey Romanenko commented on BEAM-3485: [~adejanovski] Thank you for working on this. I assume

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

[ https://issues.apache.org/jira/browse/BEAM-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437089#comment-16437089 ] Alexander Dejanovski commented on BEAM-3485: I've created a PR to fix the split generation :

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

[ https://issues.apache.org/jira/browse/BEAM-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328291#comment-16328291 ] Jean-Baptiste Onofré commented on BEAM-3485: I will fix that.  Thanks. I'm surprised as we

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

[ https://issues.apache.org/jira/browse/BEAM-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328252#comment-16328252 ] Aleksandr Sosenko commented on BEAM-3485: - Should it really be token(pk)? I've made it work when I