[HIVE-19053] RemoteSparkJobStatus#getSparkJobInfo treats all exceptions as timeout errors

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 4.0.0-alpha-1
• Component/s: Spark
• Target Version/s: 3.0.0
• Assignee: Aihua Xu
• Reporter: Sahil Takiar
• Created: 26/Mar/18 21:01
• Updated: 17/Nov/22 08:54
• Resolved: 08/Jun/18 19:03

Description

    Future<SparkJobInfo> getJobInfo = sparkClient.run(
        new GetJobInfoJob(jobHandle.getClientJobId(), sparkJobId));
    try {
      return getJobInfo.get(sparkClientTimeoutInSeconds, TimeUnit.SECONDS);
    } catch (Exception e) {
      LOG.warn("Failed to get job info.", e);
      throw new HiveException(e, ErrorMsg.SPARK_GET_JOB_INFO_TIMEOUT,
          Long.toString(sparkClientTimeoutInSeconds));
    }

It should only throw ErrorMsg.SPARK_GET_JOB_INFO_TIMEOUT if a TimeoutException is thrown. Other exceptions should be handled independently.