diff --git a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersTezSessionPoolManager.java b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersTezSessionPoolManager.java index c227a63..02002ac 100644 --- a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersTezSessionPoolManager.java +++ b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersTezSessionPoolManager.java @@ -131,14 +131,14 @@ public void testTriggerSlowQueryExecutionTime() throws Exception { runQueryWithTrigger(query, null, "Query was cancelled"); } - @Test(timeout = 60000) + @Test(timeout = 90000) public void testTriggerHighShuffleBytes() throws Exception { Expression expression = ExpressionFactory.fromString("SHUFFLE_BYTES > 100"); Trigger trigger = new ExecutionTrigger("big_shuffle", expression, Trigger.Action.KILL_QUERY); setupTriggers(Lists.newArrayList(trigger)); - String query = "select sleep(t1.under_col, 5), t1.value from " + tableName + " t1 join " + tableName + - " t2 on t1.under_col>=t2.under_col"; - runQueryWithTrigger(query, null, "Query was cancelled"); + String query = "select sleep(t1.under_col, 10), t1.value from " + tableName + " t1 join " + tableName + + " t2 on t1.under_col>=t2.under_col order by t1.under_col"; + runQueryWithTrigger(query, getConfigs(), "Query was cancelled"); } @Test(timeout = 60000)