diff --git ql/src/java/org/apache/hadoop/hive/ql/scheduled/ScheduledQueryExecutionService.java ql/src/java/org/apache/hadoop/hive/ql/scheduled/ScheduledQueryExecutionService.java index 48bdc97..813f3af 100644 --- ql/src/java/org/apache/hadoop/hive/ql/scheduled/ScheduledQueryExecutionService.java +++ ql/src/java/org/apache/hadoop/hive/ql/scheduled/ScheduledQueryExecutionService.java @@ -106,6 +106,9 @@ private void processQuery(ScheduledQueryPollResponse q) { SessionState state = null; + info = new ScheduledQueryProgressInfo(); + info.setScheduledExecutionId(q.getExecutionId()); + info.setState(QueryState.EXECUTING); try { HiveConf conf = new HiveConf(context.conf); conf.set(Constants.HIVE_QUERY_EXCLUSIVE_LOCK, lockNameFor(q.getScheduleKey())); @@ -113,9 +116,6 @@ conf.unset(HiveConf.ConfVars.HIVESESSIONID.varname); state = new SessionState(conf, q.getUser()); SessionState.start(state); - info = new ScheduledQueryProgressInfo(); - info.setScheduledExecutionId(q.getExecutionId()); - info.setState(QueryState.EXECUTING); reportQueryProgress(); try ( IDriver driver = DriverFactory.newDriver(DriverFactory.getNewQueryState(conf), null)) {