You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by pr...@apache.org on 2017/11/02 19:19:23 UTC
hive git commit: HIVE-17834: Fix flaky triggers test (Prasanth
Jayachandran reviewed by Sergey Shelukhin)
Repository: hive
Updated Branches:
refs/heads/master 77b99e4c9 -> 9f13da0a9
HIVE-17834: Fix flaky triggers test (Prasanth Jayachandran reviewed by Sergey Shelukhin)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/9f13da0a
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/9f13da0a
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/9f13da0a
Branch: refs/heads/master
Commit: 9f13da0a931db6e12a6888fb23a794de37bf93bb
Parents: 77b99e4
Author: Prasanth Jayachandran <pr...@apache.org>
Authored: Thu Nov 2 12:07:30 2017 -0700
Committer: Prasanth Jayachandran <pr...@apache.org>
Committed: Thu Nov 2 12:07:30 2017 -0700
----------------------------------------------------------------------
.../hive/jdbc/TestTriggersTezSessionPoolManager.java | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/9f13da0a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersTezSessionPoolManager.java
----------------------------------------------------------------------
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 aeca663..31bf6e8 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
@@ -138,9 +138,14 @@ public class TestTriggersTezSessionPoolManager {
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");
+ List<String> cmds = new ArrayList<>();
+ cmds.add("set hive.auto.convert.join=false");
+ // to slow down the reducer so that SHUFFLE_BYTES publishing and validation can happen, adding sleep between
+ // multiple reduce stages
+ String query = "select count(distinct t.under_col), sleep(t.under_col, 10) from (select t1.under_col from " +
+ tableName + " t1 " + "join " + tableName + " t2 on t1.under_col=t2.under_col order by sleep(t1.under_col, 0))" +
+ " t group by t.under_col";
+ runQueryWithTrigger(query, null, trigger + " violated");
}
@Test(timeout = 60000)