[
https://issues.apache.org/jira/browse/HIVE-11411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shiqian.huang updated HIVE-11411:
---------------------------------
Description:
in method progress(ExecDriverTaskHandle th) of class HadoopJobExecHelper, hive
lock heartbeating progress works with job tracking progress.
such like
heartbeater.heartbeat();
if (initializing && rj.getJobState() == JobStatus.PREP) {
// No reason to poll untill the job is initialized
continue;
} else {
// By now the job is initialized so no reason to do
// rj.getJobState() again and we do not want to do an extra RPC call
initializing = false;
}
When job tracking progress got any exception in rj.getJobState() ==
JobStatus.PREP, will bring lock time out exception to big query job.
was:in method progress(ExecDriverTaskHandle th) of class HadoopJobExecHelper,
hive lock heartbeating progress work with job tracking progress. When job
tracking progress got any exception, will bring lock time out exception to big
query job.
> Transaction lock time out when can't tracking job progress
> ----------------------------------------------------------
>
> Key: HIVE-11411
> URL: https://issues.apache.org/jira/browse/HIVE-11411
> Project: Hive
> Issue Type: Wish
> Affects Versions: 1.2.0
> Reporter: shiqian.huang
> Priority: Minor
>
> in method progress(ExecDriverTaskHandle th) of class HadoopJobExecHelper,
> hive lock heartbeating progress works with job tracking progress.
> such like
> heartbeater.heartbeat();
> if (initializing && rj.getJobState() == JobStatus.PREP) {
> // No reason to poll untill the job is initialized
> continue;
> } else {
> // By now the job is initialized so no reason to do
> // rj.getJobState() again and we do not want to do an extra RPC call
> initializing = false;
> }
> When job tracking progress got any exception in rj.getJobState() ==
> JobStatus.PREP, will bring lock time out exception to big query job.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)