Mailing-List: contact commits-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@cassandra.apache.org
Date: Thu, 6 Apr 2017 20:27:42 +0000 (UTC)
From: "Joshua McKenzie (JIRA)" <jira@apache.org>
To: commits@cassandra.apache.org
Message-ID: <JIRA.13048565.1488816221000.228668.1491510462450@Atlassian.JIRA>
In-Reply-To: <JIRA.13048565.1488816221000@Atlassian.JIRA>
References: <JIRA.13048565.1488816221000@Atlassian.JIRA> <JIRA.13048565.1488816221717@jira-lw-us.apache.org>
Subject: [jira] [Updated] (CASSANDRA-13302) last row of previous page ==
 first row of next page while querying data using SASI index
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable
archived-at: Thu, 06 Apr 2017 20:27:48 -0000


     [ https://issues.apache.org/jira/browse/CASSANDRA-13302?page=3Dcom.atl=
assian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Joshua McKenzie updated CASSANDRA-13302:
----------------------------------------
    Reviewer: Andr=C3=A9s de la Pe=C3=B1a

> last row of previous page =3D=3D first row of next page while querying da=
ta using SASI index
> -------------------------------------------------------------------------=
---------------
>
>                 Key: CASSANDRA-13302
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-1330=
2
>             Project: Cassandra
>          Issue Type: Bug
>         Environment: Tested with C* 3.9 and 3.10.
>            Reporter: Andy Tolbert
>            Assignee: Alex Petrov
>
> Apologies if this is a duplicate (couldn't track down an existing bug).
> Similarly to [CASSANDRA-11208], it appears it is possible to retrieve dup=
licate rows when paging using a SASI index as documented in [JAVA-1413|http=
s://datastax-oss.atlassian.net/browse/JAVA-1413], the following test demons=
trates that data is repeated while querying using a SASI index:
> {code:java}
> public class TestPagingBug
> {
> =09public static void main(String[] args)
> =09{
> =09=09Cluster.Builder builder =3D Cluster.builder();
> =09=09Cluster c =3D builder.addContactPoints("192.168.98.190").build();=
=09=09
> =09=09Session s =3D c.connect();
> =09=09
> =09=09s.execute("CREATE KEYSPACE IF NOT EXISTS test WITH replication =3D =
{ 'class' : 'SimpleStrategy', 'replication_factor' : 3 }");
> =09=09s.execute("CREATE TABLE IF NOT EXISTS test.test_table_sec(sec BIGIN=
T PRIMARY KEY, id INT)");
>                 //create secondary index on ID column, used for select st=
atement
>                 String index =3D "CREATE CUSTOM INDEX test_table_sec_idx =
ON test.test_table_sec (id) USING 'org.apache.cassandra.index.sasi.SASIInde=
x' "
>                 + "WITH OPTIONS =3D { 'mode': 'PREFIX' }";
>                 s.execute(index);
> =09=09
> =09=09PreparedStatement insert =3D s.prepare("INSERT INTO test.test_table=
_sec (id, sec) VALUES (1, ?)");=09=09
> =09=09for (int i =3D 0; i < 1000; i++)
> =09=09=09s.execute(insert.bind((long) i));
> =09=09
> =09=09PreparedStatement select =3D s.prepare("SELECT sec FROM test.test_t=
able_sec WHERE id =3D 1");
> =09=09
> =09=09long lastSec =3D -1;=09=09
> =09=09for (Row row : s.execute(select.bind().setFetchSize(300)))
> =09=09{
> =09=09=09long sec =3D row.getLong("sec");
> =09=09=09if (sec =3D=3D lastSec)
> =09=09=09=09System.out.println(String.format("Duplicated id %d", sec));
> =09=09=09
> =09=09=09lastSec =3D sec;
> =09=09}
> =09=09System.exit(0);
> =09}
> }
> {code}
> The program outputs the following:
> {noformat}
> Duplicated id 23
> Duplicated id 192
> Duplicated id 684
> {noformat}
> Note that the simple primary key is required to reproduce this.


--
This message was sent by Atlassian JIRA
(v6.3.15#6346)