Skip to content

Instantly share code, notes, and snippets.

@rajkrrsingh
Last active July 20, 2019 12:06
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 1 You must be signed in to fork a gist
  • Save rajkrrsingh/3ec675f20f55b302f4e931fd3b92975d to your computer and use it in GitHub Desktop.
Save rajkrrsingh/3ec675f20f55b302f4e931fd3b92975d to your computer and use it in GitHub Desktop.
hive llap workload management commands

Create RESOURCE PLAN testrp;

create RESOURCE PLAN testrp;
CREATE POOL testrp.default.c1 WITH ALLOC_FRACTION=0.3, QUERY_PARALLELISM=3, SCHEDULING_POLICY='fair';
CREATE POOL testrp.default.c2 WITH ALLOC_FRACTION=0.5, QUERY_PARALLELISM=1, SCHEDULING_POLICY='fair';
SELECT * FROM SYS.WM_POOLS;
ALTER RESOURCE PLAN testrp VALIDATE;
ALTER RESOURCE PLAN testrp ENABLE ACTIVATE;

This will fail with error - Sum of children pools' alloc fraction should be less than 1 got: 1.0 for pool: default

create RESOURCE PLAN testrp1;
CREATE POOL testrp1.default.c1 WITH ALLOC_FRACTION=0.3, QUERY_PARALLELISM=3, SCHEDULING_POLICY='fair';
CREATE POOL testrp1.default.c2 WITH ALLOC_FRACTION=0.7, QUERY_PARALLELISM=1, SCHEDULING_POLICY='fair';
SELECT * FROM SYS.WM_POOLS;
ALTER RESOURCE PLAN testrp1 VALIDATE;
ALTER RESOURCE PLAN testrp1 ENABLE ACTIVATE;

This will SUCCEEDED

create RESOURCE PLAN testrp2;
CREATE POOL testrp2.default.c1 WITH ALLOC_FRACTION=0.3, QUERY_PARALLELISM=3, SCHEDULING_POLICY='fair';
CREATE POOL testrp2.default.c2 WITH ALLOC_FRACTION=0.6, QUERY_PARALLELISM=2, SCHEDULING_POLICY='fair';
SELECT * FROM SYS.WM_POOLS;
ALTER RESOURCE PLAN testrp2 VALIDATE;
ALTER RESOURCE PLAN testrp2 ENABLE ACTIVATE;

Disable resource plan

ALTER RESOURCE PLAN testrp2 DISABLE;

Disable workload management

DISABLE WORKLOAD MANAGEMENT

Show Resource Plan

SHOW RESOURCE PLANS;
SELECT * FROM SYS.WM_RESOURCEPLANS;

Show pools

SELECT * FROM SYS.WM_POOLS;

Alter pools

ALTER POOL plan_2.default.c2 SET SCHEDULING_POLICY='fair';
ALTER POOL plan_2.default.c2 UNSET SCHEDULING_POLICY;
ALTER POOL plan_2.default SET path = def;
SELECT * FROM SYS.WM_POOLS;


ALTER POOL testrp2.default SET  QUERY_PARALLELISM = 2;
ALTER POOL testrp2.default.c1 SET  QUERY_PARALLELISM = 1;
ALTER POOL testrp2.default.c2 SET  QUERY_PARALLELISM = 1;

DROP POOL plan_2.default;
SELECT * FROM SYS.WM_POOLS;


Create Trigger

CREATE TRIGGER testrp2.trigger_1 WHEN ELAPSED_TIME > 300 DO KILL

ADD trigger to the pool

ALTER POOL testrp2.default ADD TRIGGER trigger_1

Drop Trigger

DROP TRIGGER plan_1.trigger_1;

Show Triggers on pool

SELECT * FROM SYS.WM_POOLS_TO_TRIGGERS;

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment