natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SelectTest.testMixedTTLOnColumnsWide is flaky 

Patch by Jeff Jirsa; Reviewed by Joel Knighton for CASSANDRA-13764
This commit is contained in:
Jeff Jirsa 2017-08-29 12:43:38 -07:00
parent e817c83bc0
commit 67ac1496cc
1 changed files with 37 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
test/unit/org/apache/cassandra/cql3/validation/operations/SelectTest.java
View File

@ -2973,8 +2973,24 @@ public class SelectTest extends CQLTester
execute("INSERT INTO %s (k) VALUES (2);"); execute("INSERT INTO %s (k) VALUES (2);");
execute("INSERT INTO %s (k, i) VALUES (1, 1) USING TTL 100;"); execute("INSERT INTO %s (k, i) VALUES (1, 1) USING TTL 100;");
execute("INSERT INTO %s (k, i) VALUES (3, 3) USING TTL 100;"); execute("INSERT INTO %s (k, i) VALUES (3, 3) USING TTL 100;");
assertRows(execute("SELECT k, i, TTL(i) FROM %s "), assertRows(execute("SELECT k, i FROM %s "),
row(1, 1, 100), row(2, null, null), row(3, 3, 100)); row(1, 1),
row(2, null),
row(3, 3));
UntypedResultSet rs = execute("SELECT k, i, ttl(i) AS name_ttl FROM %s");
assertEquals("name_ttl", rs.metadata().get(2).name.toString());
int i = 0;
for (UntypedResultSet.Row row : rs)
{
if ( i % 2 == 0) // Every odd row has a null i/ttl
assertTrue(row.getInt("name_ttl") >= 90 && row.getInt("name_ttl") <= 100);
else
assertTrue(row.has("name_ttl") == false);
i++;
}
} }
@Test @Test
@ -2986,11 +3002,24 @@ public class SelectTest extends CQLTester
execute("INSERT INTO %s (k, c) VALUES (1, 2) ;"); execute("INSERT INTO %s (k, c) VALUES (1, 2) ;");
execute("INSERT INTO %s (k, c, i) VALUES (1, 3, 3) USING TTL 100;"); execute("INSERT INTO %s (k, c, i) VALUES (1, 3, 3) USING TTL 100;");
execute("INSERT INTO %s (k, c, i) VALUES (3, 3, 3) USING TTL 100;"); execute("INSERT INTO %s (k, c, i) VALUES (3, 3, 3) USING TTL 100;");
assertRows(execute("SELECT k, c, i, TTL(i) FROM %s "), assertRows(execute("SELECT k, c, i FROM %s "),
row(1, 1, 1, 100), row(1, 1, 1),
row(1, 2, null, null), row(1, 2, null),
row(1, 3, 3, 100), row(1, 3, 3),
row(2, 2, null, null), row(2, 2, null),
row(3, 3, 3, 100)); row(3, 3, 3));
UntypedResultSet rs = execute("SELECT k, c, i, ttl(i) AS name_ttl FROM %s");
assertEquals("name_ttl", rs.metadata().get(3).name.toString());
int i = 0;
for (UntypedResultSet.Row row : rs)
{
if ( i % 2 == 0) // Every odd row has a null i/ttl
assertTrue(row.getInt("name_ttl") >= 90 && row.getInt("name_ttl") <= 100);
else
assertTrue(row.has("name_ttl") == false);
i++;
}
} }
} }