Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -185,9 +185,9 @@ public void testAvgGroupByOrderPreservingWithStats() throws Exception {
assertEquals(13,rs.getInt(1));
testAvgGroupByOrderPreserving(conn, tableName, 13);
conn.createStatement().execute("ALTER TABLE " + tableName + " SET " + PhoenixDatabaseMetaData.GUIDE_POSTS_WIDTH + "=100");
testAvgGroupByOrderPreserving(conn, tableName, 6);
testAvgGroupByOrderPreserving(conn, tableName, 8);
conn.createStatement().execute("ALTER TABLE " + tableName + " SET " + PhoenixDatabaseMetaData.GUIDE_POSTS_WIDTH + "=null");
testAvgGroupByOrderPreserving(conn, tableName, 4);
testAvgGroupByOrderPreserving(conn, tableName, 7);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -483,7 +483,7 @@ public void testAvgGroupByOrderPreservingWithNoStats() throws Exception {
Connection conn = DriverManager.getConnection(getUrl(), props);
String tableName = generateUniqueName();
initAvgGroupTable(conn, tableName, "");
testAvgGroupByOrderPreserving(conn, tableName, 4);
testAvgGroupByOrderPreserving(conn, tableName, 7);
}

protected void initAvgGroupTable(Connection conn, String tableName, String tableProps) throws SQLException {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ public BaseViewIT( String txProvider) {
public static Collection<Object[]> data() {
return TestUtil.filterTxParamData(Arrays.asList(new Object[][] { {"TEPHRA"}, {"OMID"}, {null} }), 0);
}

protected void testUpdatableViewWithIndex(Integer saltBuckets, boolean localIndex) throws Exception {
String viewName = testUpdatableView(saltBuckets);
Pair<String,Scan> pair = testUpdatableViewIndex(saltBuckets, localIndex, viewName);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -63,19 +63,6 @@ public class ConcurrentMutationsIT extends ParallelStatsDisabledIT {

private final Object lock = new Object();

private static class MyClock extends EnvironmentEdge {
public volatile long time;

public MyClock (long time) {
this.time = time;
}

@Override
public long currentTime() {
return time;
}
}

@Test
public void testSynchronousDeletesAndUpsertValues() throws Exception {
final String tableName = generateUniqueName();
Expand Down

Large diffs are not rendered by default.

Loading