diff --git ql/src/test/queries/clientpositive/schq_analyze.q ql/src/test/queries/clientpositive/schq_analyze.q index 246a215..c156f9f 100644 --- ql/src/test/queries/clientpositive/schq_analyze.q +++ ql/src/test/queries/clientpositive/schq_analyze.q @@ -17,7 +17,7 @@ desc formatted t; -- create a schedule to compute stats -create scheduled query t_analyze cron '0 */1 * * * ? *' as analyze table t compute statistics for columns; +create scheduled query t_analyze cron '0 0 0 1 * ? 2030' as analyze table t compute statistics for columns; alter scheduled query t_analyze execute; diff --git ql/src/test/queries/clientpositive/schq_ingest.q ql/src/test/queries/clientpositive/schq_ingest.q index 8ffc722..5fc9123 100644 --- ql/src/test/queries/clientpositive/schq_ingest.q +++ ql/src/test/queries/clientpositive/schq_ingest.q @@ -26,8 +26,8 @@ insert into t select id,cnt where not first insert overwrite table t_offset select max(s1.id); --- configure to run ingestion every 10 minutes -create scheduled query ingest every 10 minutes defined as +-- configure to run ingestion every 2 days +create scheduled query ingest cron '0 0 0 1 * ? 2030' defined as from (select id==offset as first,* from s join t_offset on id>=offset) s1 insert into t select id,cnt where not first diff --git ql/src/test/queries/clientpositive/schq_materialized.q ql/src/test/queries/clientpositive/schq_materialized.q index 46b725e..946c191 100644 --- ql/src/test/queries/clientpositive/schq_materialized.q +++ ql/src/test/queries/clientpositive/schq_materialized.q @@ -60,7 +60,7 @@ WHERE hire_date >= '2018-01-01'; -- create a schedule to rebuild mv -create scheduled query d cron '0 0 * * * ? *' defined as +create scheduled query d cron '0 0 0 1 * ? 2030' defined as alter materialized view mv1 rebuild; set hive.support.quoted.identifiers=none; diff --git ql/src/test/results/clientpositive/llap/schq_analyze.q.out ql/src/test/results/clientpositive/llap/schq_analyze.q.out index a083479..4824557 100644 --- ql/src/test/results/clientpositive/llap/schq_analyze.q.out +++ ql/src/test/results/clientpositive/llap/schq_analyze.q.out @@ -53,9 +53,9 @@ Sort Columns: [] Storage Desc Params: serialization.format 1 -PREHOOK: query: create scheduled query t_analyze cron '0 */1 * * * ? *' as analyze table t compute statistics for columns +PREHOOK: query: create scheduled query t_analyze cron '0 0 0 1 * ? 2030' as analyze table t compute statistics for columns PREHOOK: type: CREATE SCHEDULED QUERY -POSTHOOK: query: create scheduled query t_analyze cron '0 */1 * * * ? *' as analyze table t compute statistics for columns +POSTHOOK: query: create scheduled query t_analyze cron '0 0 0 1 * ? 2030' as analyze table t compute statistics for columns POSTHOOK: type: CREATE SCHEDULED QUERY PREHOOK: query: alter scheduled query t_analyze execute PREHOOK: type: ALTER SCHEDULED QUERY diff --git ql/src/test/results/clientpositive/llap/schq_ingest.q.out ql/src/test/results/clientpositive/llap/schq_ingest.q.out index 19d2b11..8e5c123 100644 --- ql/src/test/results/clientpositive/llap/schq_ingest.q.out +++ ql/src/test/results/clientpositive/llap/schq_ingest.q.out @@ -76,13 +76,13 @@ POSTHOOK: Lineage: t.id SIMPLE [(s)s.FieldSchema(name:id, type:int, comment:null), ] POSTHOOK: Lineage: t_offset.offset EXPRESSION [(s)s.FieldSchema(name:id, type:int, comment:null), ] Warning: Shuffle Join MERGEJOIN[34][tables = [s, t_offset]] in Stage 'Reducer 2' is a cross product -PREHOOK: query: create scheduled query ingest every 10 minutes defined as +PREHOOK: query: create scheduled query ingest cron '0 0 0 1 * ? 2030' defined as from (select id==offset as first,* from s join t_offset on id>=offset) s1 insert into t select id,cnt where not first insert overwrite table t_offset select max(s1.id) PREHOOK: type: CREATE SCHEDULED QUERY -POSTHOOK: query: create scheduled query ingest every 10 minutes defined as +POSTHOOK: query: create scheduled query ingest cron '0 0 0 1 * ? 2030' defined as from (select id==offset as first,* from s join t_offset on id>=offset) s1 insert into t select id,cnt where not first diff --git ql/src/test/results/clientpositive/llap/schq_materialized.q.out ql/src/test/results/clientpositive/llap/schq_materialized.q.out index ff86bb5..43631b5 100644 --- ql/src/test/results/clientpositive/llap/schq_materialized.q.out +++ ql/src/test/results/clientpositive/llap/schq_materialized.q.out @@ -263,10 +263,10 @@ Processor Tree: ListSink -PREHOOK: query: create scheduled query d cron '0 0 * * * ? *' defined as +PREHOOK: query: create scheduled query d cron '0 0 0 1 * ? 2030' defined as alter materialized view mv1 rebuild PREHOOK: type: CREATE SCHEDULED QUERY -POSTHOOK: query: create scheduled query d cron '0 0 * * * ? *' defined as +POSTHOOK: query: create scheduled query d cron '0 0 0 1 * ? 2030' defined as alter materialized view mv1 rebuild POSTHOOK: type: CREATE SCHEDULED QUERY PREHOOK: query: select `(NEXT_EXECUTION|SCHEDULED_QUERY_ID)?+.+` from sys.scheduled_queries @@ -277,7 +277,7 @@ POSTHOOK: type: QUERY POSTHOOK: Input: sys@scheduled_queries #### A masked pattern was here #### -d true hive 0 0 * * * ? * hive_admin_user alter materialized view `default`.`mv1` rebuild NULL +d true hive 0 0 0 1 * ? 2030 hive_admin_user alter materialized view `default`.`mv1` rebuild NULL PREHOOK: query: alter scheduled query d execute PREHOOK: type: ALTER SCHEDULED QUERY POSTHOOK: query: alter scheduled query d execute