Fix TestDistributedQueryResource
@@ -59,7 +59,7 @@ public class TestDistributedQueryResource
throws Exception
{
client = new JettyHttpClient();
- DistributedQueryRunner runner = createQueryRunner(ImmutableMap.of("query.client.timeout", "20s"), 2);
+ DistributedQueryRunner runner = createQueryRunner(ImmutableMap.of("query.client.timeout", "30s", "resource-manager.query-expiration-timeout", "2m"), 2);
coordinator1 = runner.getCoordinators().get(0);
coordinator2 = runner.getCoordinators().get(1);
Optional<TestingPrestoServer> resourceManager = runner.getResourceManager();
@@ -127,7 +127,7 @@ public class TestDistributedQueryResource
assertStateCounts(infos, 0, 0, 0, 1);
// Sleep to trigger client query expiration
- sleep(SECONDS.toMillis(20));
+ sleep(SECONDS.toMillis(30));
infos = getQueryInfos(coordinator2, "/v1/query?state=failed");
assertEquals(infos.size(), 5);
